diff --git a/beat/core/bcp/worker.py b/beat/core/bcp/worker.py
index 2ec25c5f53a89718c30a8438371fa3e5a1415a02..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
@@ -183,6 +183,8 @@ def run(
             if command == BCP.BCPE_EXECUTE:
                 job_id = request.pop(0)
                 job_data = request.pop(0)
+                if sys.version_info < (3, 6):
+                    job_data = job_data.decode("utf-8")
                 data = json.loads(job_data)
 
                 reply = [BCP.BCPP_JOB_RECEIVED, job_id]