{"timestamp": "2026-04-07T08:17:06.123493", "level": "LIFECYCLE", "logger": "shared.queue_broker.worker", "message": "Lifecycle task_start status=STARTED message_id=13694 task_name=sync_data_transmission image=desisivio/platform-worker:develop image_digest=sha256:cc0a4ff70e00b27bc2ff5ca8042d2918630f70a657c6844bb3d913f41ab1c9ab", "module": "worker", "function": "_process_message", "line": 801, "task_type": "sync_data_transmission", "task_id": "9", "run_type": null, "persist_logging": true, "message_id": "13694", "event_type": "LIFECYCLE"}
{"timestamp": "2026-04-07T08:17:06.560712", "level": "ERROR", "logger": "shared.pipelines.pipeline_utils", "message": "Error calling rclone to obscure password.", "module": "pipeline_utils", "function": "get_full_connection_string", "line": 456, "task_type": "sync_data_transmission", "task_id": "9", "run_type": null, "persist_logging": true, "message_id": "13694", "event_type": null, "exception": "requests.exceptions.ConnectionError: HTTPConnectionPool(host='127.0.0.1', port=5572): Max retries exceeded with url: /core/obscure (Caused by NewConnectionError(\"HTTPConnection(host='127.0.0.1', port=5572): Failed to establish a new connection: [Errno 111] Connection refused\"))", "traceback": "  File \"/worker/shared/pipelines/pipeline_utils.py\", line 450, in get_full_connection_string\n    obscure_response = requests.post(\n                       ^^^^^^^^^^^^^^\n  File \"/usr/local/lib/python3.12/site-packages/requests/api.py\", line 115, in post\n    return request(\"post\", url, data=data, json=json, **kwargs)\n           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n  File \"/usr/local/lib/python3.12/site-packages/requests/api.py\", line 59, in request\n    return session.request(method=method, url=url, **kwargs)\n           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n  File \"/usr/local/lib/python3.12/site-packages/requests/sessions.py\", line 592, in request\n    resp = self.send(prep, **send_kwargs)\n           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n  File \"/usr/local/lib/python3.12/site-packages/requests/sessions.py\", line 706, in send\n    r = adapter.send(request, **kwargs)\n        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n  File \"/usr/local/lib/python3.12/site-packages/requests/adapters.py\", line 678, in send\n    raise ConnectionError(e, request=request)\n"}
{"timestamp": "2026-04-07T08:17:06.565598", "level": "ERROR", "logger": "shared.pipelines.pipeline_utils", "message": "Exception in get_full_connection_string: Exception", "module": "pipeline_utils", "function": "get_full_connection_string", "line": 396, "task_type": "sync_data_transmission", "task_id": "9", "run_type": null, "persist_logging": true, "message_id": "13694", "event_type": null, "exception": "Exception: Error calling rclone to get SFTP obscured password for connection string. HTTPConnectionPool(host='127.0.0.1', port=5572): Max retries exceeded with url: /core/obscure (Caused by NewConnectionError(\"HTTPConnection(host='127.0.0.1', port=5572): Failed to establish a new connection: [Errno 111] Connection refused\"))", "traceback": "  File \"/worker/shared/logging/ps_logging.py\", line 132, in wrapper\n    result = func(*args, **kwargs)\n             ^^^^^^^^^^^^^^^^^^^^^\n  File \"/worker/shared/pipelines/pipeline_utils.py\", line 457, in get_full_connection_string\n    raise Exception(\n"}
{"timestamp": "2026-04-07T08:17:06.567142", "level": "ERROR", "logger": "shared.pipelines.pipeline_utils", "message": "Error getting connection string for datasource remoteSFTP: Error calling rclone to get SFTP obscured password for connection string. HTTPConnectionPool(host='127.0.0.1', port=5572): Max retries exceeded with url: /core/obscure (Caused by NewConnectionError(\"HTTPConnection(host='127.0.0.1', port=5572): Failed to establish a new connection: [Errno 111] Connection refused\"))", "module": "pipeline_utils", "function": "get_datasource_by_mnemonic", "line": 384, "task_type": "sync_data_transmission", "task_id": "9", "run_type": null, "persist_logging": true, "message_id": "13694", "event_type": null, "exception": "Exception: Error calling rclone to get SFTP obscured password for connection string. HTTPConnectionPool(host='127.0.0.1', port=5572): Max retries exceeded with url: /core/obscure (Caused by NewConnectionError(\"HTTPConnection(host='127.0.0.1', port=5572): Failed to establish a new connection: [Errno 111] Connection refused\"))", "traceback": "  File \"/worker/shared/pipelines/pipeline_utils.py\", line 382, in get_datasource_by_mnemonic\n    conn_string = get_full_connection_string(datasource_model)\n                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n  File \"/worker/shared/logging/ps_logging.py\", line 132, in wrapper\n    result = func(*args, **kwargs)\n             ^^^^^^^^^^^^^^^^^^^^^\n  File \"/worker/shared/pipelines/pipeline_utils.py\", line 457, in get_full_connection_string\n    raise Exception(\n"}
{"timestamp": "2026-04-07T08:17:06.568589", "level": "ERROR", "logger": "shared.pipelines.pipeline_utils", "message": "Exception in get_datasource_by_mnemonic: ValueError", "module": "pipeline_utils", "function": "get_datasource_by_mnemonic", "line": 317, "task_type": "sync_data_transmission", "task_id": "9", "run_type": null, "persist_logging": true, "message_id": "13694", "event_type": null, "exception": "ValueError: Error getting connection string for datasource remoteSFTP: Error calling rclone to get SFTP obscured password for connection string. HTTPConnectionPool(host='127.0.0.1', port=5572): Max retries exceeded with url: /core/obscure (Caused by NewConnectionError(\"HTTPConnection(host='127.0.0.1', port=5572): Failed to establish a new connection: [Errno 111] Connection refused\"))", "traceback": "  File \"/worker/shared/logging/ps_logging.py\", line 132, in wrapper\n    result = func(*args, **kwargs)\n             ^^^^^^^^^^^^^^^^^^^^^\n  File \"/worker/shared/pipelines/pipeline_utils.py\", line 387, in get_datasource_by_mnemonic\n    raise ValueError(\n"}
{"timestamp": "2026-04-07T08:17:06.571048", "level": "ERROR", "logger": "shared.queue_broker.worker", "message": "Error processing id=13694: Task failed: Error getting connection string for datasource remoteSFTP: Error calling rclone to get SFTP obscured password for connection string. HTTPConnectionPool(host='127.0.0.1', port=5572): Max retries exceeded with url: /core/obscure (Caused by NewConnectionError(\"HTTPConnection(host='127.0.0.1', port=5572): Failed to establish a new connection: [Errno 111] Connection refused\"))", "module": "worker", "function": "_process_message", "line": 820, "task_type": "sync_data_transmission", "task_id": "9", "run_type": null, "persist_logging": true, "message_id": "13694", "event_type": null}
{"timestamp": "2026-04-07T08:17:06.573774", "level": "LIFECYCLE", "logger": "shared.queue_broker.worker", "message": "Lifecycle task_end status=FAILED message_id=13694 task_name=sync_data_transmission", "module": "worker", "function": "run", "line": 502, "task_type": "sync_data_transmission", "task_id": "9", "run_type": null, "persist_logging": true, "message_id": "13694", "event_type": "LIFECYCLE"}