Compare commits
3 Commits
Author | SHA1 | Date |
---|---|---|
lash | 1dc2e727d3 | |
lash | 2607599e16 | |
lash | d439a2028f |
|
@ -1,2 +1,5 @@
|
|||
- 0.13.1
|
||||
* Reverse order of queue and task name in task callbacks config
|
||||
* Add method setter for callback filter
|
||||
- 0.13.0
|
||||
* Receive filters and unit tests from cic-stack/cic-eth 0.12.10
|
||||
|
|
|
@ -34,6 +34,15 @@ class CallbackFilter(SyncFilter):
|
|||
|
||||
trusted_addresses = []
|
||||
|
||||
def __init__(self, chain_spec, registry, queue, caller_address=ZERO_ADDRESS):
|
||||
super(CallbackFilter, self).__init__(chain_spec, registry, queue, caller_address=caller_address)
|
||||
self.method = None
|
||||
|
||||
|
||||
def set_method(self, method):
|
||||
self.method = method
|
||||
|
||||
|
||||
def call_back(self, transfer_type, result):
|
||||
result['chain_spec'] = result['chain_spec'].asdict()
|
||||
s = celery.signature(
|
||||
|
|
Loading…
Reference in New Issue