diff --git a/beat/core/bcp/worker.py b/beat/core/bcp/worker.py index b0745646b05ebafae91c7af56ce88f5f0ee31a94..0b53c7562cace5407e803db6a175f2fe9a397aff 100644 --- a/beat/core/bcp/worker.py +++ b/beat/core/bcp/worker.py @@ -134,7 +134,7 @@ def run( worker_address = "tcp://localhost:{}".format(port) worker = BeatComputationWorker(poller, broker_address, service_name, verbose == 3) - processor = BeatComputationProcessor(poller, processor_address, True) # verbose==3) + processor = BeatComputationProcessor(poller, processor_address, verbose == 3) execution_processes = [] global stop