diff options
Diffstat (limited to 'taskflow/engines/worker_based/protocol.py')
| -rw-r--r-- | taskflow/engines/worker_based/protocol.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/taskflow/engines/worker_based/protocol.py b/taskflow/engines/worker_based/protocol.py index bd95501..1784ab3 100644 --- a/taskflow/engines/worker_based/protocol.py +++ b/taskflow/engines/worker_based/protocol.py @@ -93,6 +93,10 @@ QUEUE_EXPIRE_TIMEOUT = REQUEST_TIMEOUT # Workers notify period. NOTIFY_PERIOD = 5 +# When a worker hasn't notified in this many seconds, it will get expired from +# being used/targeted for further work. +EXPIRES_AFTER = 60 + # Message types. NOTIFY = 'NOTIFY' REQUEST = 'REQUEST' |