ppf: fix worker_id undefined when using --worker-key
This commit is contained in:
2
ppf.py
2
ppf.py
@@ -493,6 +493,7 @@ def worker_main(config):
|
|||||||
worker_name = config.args.worker_name or os.uname()[1]
|
worker_name = config.args.worker_name or os.uname()[1]
|
||||||
batch_size = config.worker.batch_size
|
batch_size = config.worker.batch_size
|
||||||
num_threads = config.watchd.threads
|
num_threads = config.watchd.threads
|
||||||
|
worker_id = None
|
||||||
|
|
||||||
# Register if --register flag or no key provided
|
# Register if --register flag or no key provided
|
||||||
if config.args.register or not worker_key:
|
if config.args.register or not worker_key:
|
||||||
@@ -798,6 +799,7 @@ def worker_v2_main(config):
|
|||||||
worker_name = config.args.worker_name or os.uname()[1]
|
worker_name = config.args.worker_name or os.uname()[1]
|
||||||
num_threads = config.watchd.threads
|
num_threads = config.watchd.threads
|
||||||
url_batch_size = config.worker.url_batch_size
|
url_batch_size = config.worker.url_batch_size
|
||||||
|
worker_id = None
|
||||||
|
|
||||||
# Register if --register flag or no key provided
|
# Register if --register flag or no key provided
|
||||||
if config.args.register or not worker_key:
|
if config.args.register or not worker_key:
|
||||||
|
|||||||
Reference in New Issue
Block a user