diff options
| author | Joshua Harlow <harlowja@gmail.com> | 2014-12-25 12:38:08 -0800 |
|---|---|---|
| committer | Joshua Harlow <harlowja@gmail.com> | 2014-12-25 12:52:48 -0800 |
| commit | d498fdb1f6aa9898facedb815751da0e912e3fe0 (patch) | |
| tree | d1b041acb795472be40f99eb9fb66145d9e0a00f /taskflow/engines/action_engine/executor.py | |
| parent | 143fb171dea3ffe2439c1347658555aacf9c8b7f (diff) | |
| download | taskflow-d498fdb1f6aa9898facedb815751da0e912e3fe0.tar.gz | |
Register with 'ANY' in the cloned process
Seems like we should have registered with 'ANY' since
otherwise if a cloned task emits a unknown notification
then the 'ANY' event should be triggered instead of not
being emitted.
Change-Id: Iedd3c0eb034043ba8e5b9e9a02a6e49c451e17b3
Diffstat (limited to 'taskflow/engines/action_engine/executor.py')
| -rw-r--r-- | taskflow/engines/action_engine/executor.py | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/taskflow/engines/action_engine/executor.py b/taskflow/engines/action_engine/executor.py index 5d063c5..3414205 100644 --- a/taskflow/engines/action_engine/executor.py +++ b/taskflow/engines/action_engine/executor.py @@ -428,10 +428,6 @@ class ParallelProcessTaskExecutor(ParallelTaskExecutor): for (event_type, listeners) in task.notifier.listeners_iter(): if listeners: needed.add(event_type) - # We don't register for the 'ANY' event; since that meta event type - # will be correctly proxied by the task notifier directly without - # needing clone replication. - needed.discard(task.notifier.ANY) if progress_callback is not None: needed.add(_UPDATE_PROGRESS) for event_type in needed: |