2026-08-12T14:00:11Z ATTEMPT_START role=fixed attempt=2 expect=fixed repo=/workspace/bundle/repro/worktrees/fixed commit=b29849f8abb08d78f257e6106b6111a8a1b0e621 2026-08-12T14:00:11Z RUNTIME_CONFIG ossec_conf=/workspace/bundle/repro/worktrees/fixed/etc/ossec.conf cluster_port=1516 daemon_pidfiles=wazuh-modulesd,wazuh-analysisd,wazuh-execd,wazuh-db,wazuh-remoted 2026-08-12T14:00:11Z SOURCE_MODULES {"common_py": "/workspace/bundle/repro/worktrees/fixed/framework/wazuh/core/cluster/common.py", "dapi_py": "/workspace/bundle/repro/worktrees/fixed/framework/wazuh/core/cluster/dapi/dapi.py", "master_py": "/workspace/bundle/repro/worktrees/fixed/framework/wazuh/core/cluster/master.py", "results_py": "/workspace/bundle/repro/worktrees/fixed/framework/wazuh/core/results.py"} 2026-08-12T14:00:11Z PRODUCT_CLASSES master_handler=wazuh.core.cluster.master.MasterHandler handler=wazuh.core.cluster.common.Handler distributed_api=wazuh.core.cluster.dapi.dapi.DistributedAPI 2026-08-12T14:00:11Z MALICIOUS_RESPONSE path=/workspace/bundle/repro/evil_worker_response.json bytes=584 sha256=0263321204e3329170522648eac55056273dec224ae934ecf7ceb0e64f3c52b6 2026-08-12T14:00:11Z MASTER_LISTENING original_wazuh_cluster_tcp=127.0.0.1:1516 requested_port=1516 fallback_used=False fernet_key_len=32 INFO:wazuh:Connection from ('127.0.0.1', 36578) 2026-08-12T14:00:11Z WORKER_TX_FRAME command=b'hello' counter=2878595054 plaintext_len=28 encrypted_payload_len=120 frame_sha256=3dcebaacd18cdfc71168fb682a75deb9711c06713a21c4427fa91fbcbdd8d3fd header_cmd=b'hello ------' DEBUG:wazuh:Command received: b'hello' 2026-08-12T14:00:11Z WORKER_RX_FRAME command=b'ok' counter=2878595054 plaintext_len=21 payload_head=b'Client worker01 added' 2026-08-12T14:00:11Z WORKER_HELLO_ACCEPTED response=b'Client worker01 added' 2026-08-12T14:00:11Z MASTER_CONNECTED_WORKERS=['worker01'] 2026-08-12T14:00:11Z MASTER_CALL_DAPI DistributedAPI.distribute_function request_type=distributed_master node_list=worker01,master01 DEBUG:wazuh.dapi:Receiving parameters {'node_list': ['worker01', 'master01']} DEBUG:wazuh:Command received: b'get_nodes' DEBUG:wazuh.dapi:Receiving parameters {} DEBUG:wazuh.dapi:Starting to execute request locally DEBUG:wazuh.dapi:Finished executing request locally DEBUG:wazuh.dapi:Time calculating request (get_node_wrapper) result: 0.002s 2026-08-12T14:00:11Z WORKER_RX_FRAME command=b'dapi' counter=3786488265 plaintext_len=587 payload_head=b'84174b48-43e8-4df4-8d72-1d84ae10db54 {"f": {"__callable__": {"__name__": "get_node_wrapper", "__module__": "wazuh.cluster", "__qualname__": "get_node_wrapper", "__type__": "functio' 2026-08-12T14:00:11Z WORKER_GOT_DAPI_REQUEST request_id=84174b48-43e8-4df4-8d72-1d84ae10db54 json_len=550 json_sha256=48a2aa80988395bd0b9dc9b3197248e69b7bde7c140f11f8e60bee33e9004283 json_head=b'{"f": {"__callable__": {"__name__": "get_node_wrapper", "__module__": "wazuh.cluster", "__qualname__": "get_node_wrapper", "__type__": "function"}}, "f_kwargs": {}, "request_type": "distributed_master", "wait_for_complet' 2026-08-12T14:00:11Z WORKER_TX_FRAME command=b'ok' counter=3786488265 plaintext_len=35 encrypted_payload_len=140 frame_sha256=549b4688a19509d12f1c654d12706ef5035bbd1d5e240f67b3cee1795a62c5aa header_cmd=b'ok ---------' 2026-08-12T14:00:11Z WORKER_TX_FRAME command=b'new_str' counter=2878595055 plaintext_len=3 encrypted_payload_len=100 frame_sha256=9b0088db1dcc043216ff0665de748301b12d8381d1a33bb04110f15840c47488 header_cmd=b'new_str ----' DEBUG:wazuh:Command received: b'new_str' 2026-08-12T14:00:11Z WORKER_RX_FRAME command=b'ok' counter=2878595055 plaintext_len=10 payload_head=b'3794955124' 2026-08-12T14:00:11Z WORKER_SEND_STRING_RESERVED string_id=b'3794955124' response_bytes=584 2026-08-12T14:00:11Z WORKER_TX_FRAME command=b'str_upd' counter=2878595056 plaintext_len=595 encrypted_payload_len=888 frame_sha256=4987d244675621df85a703814a67a27a44e01fb808ad753a92c090d1bbc7458c header_cmd=b'str_upd ----' DEBUG:wazuh:Command received: b'str_upd' 2026-08-12T14:00:11Z WORKER_RX_FRAME command=b'ok' counter=2878595056 plaintext_len=14 payload_head=b'String updated' 2026-08-12T14:00:11Z WORKER_SEND_STRING_UPDATED malicious JSON stored in master MasterHandler.in_str 2026-08-12T14:00:11Z WORKER_TX_FRAME command=b'dapi_res' counter=2878595057 plaintext_len=47 encrypted_payload_len=140 frame_sha256=2ce91fd22663238042c069d89e646e09d97c94d3b437976bee338c175def44ff header_cmd=b'dapi_res ---' DEBUG:wazuh:Command received: b'dapi_res' 2026-08-12T14:00:11Z WORKER_RX_FRAME command=b'ok' counter=2878595057 plaintext_len=18 payload_head=b'Forwarded response' 2026-08-12T14:00:11Z WORKER_DAPI_RES_ACKNOWLEDGED master accepted dapi_res and released pending DistributedAPI request ERROR:wazuh.dapi:Wazuh Internal Error: Invalid sort_casting type 'exec'. Allowed types: bool, float, int, str Traceback (most recent call last): File "/workspace/bundle/repro/worktrees/fixed/framework/wazuh/core/cluster/dapi/dapi.py", line 174, in distribute_function response = await self.forward_request() ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "/workspace/bundle/repro/worktrees/fixed/framework/wazuh/core/cluster/dapi/dapi.py", line 569, in forward_request response = await asyncio.shield(asyncio.gather(*[forward(node) for node in cleaned_valid_nodes])) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "/workspace/bundle/repro/worktrees/fixed/framework/wazuh/core/cluster/dapi/dapi.py", line 478, in forward result = json.loads(await client.execute(b'dapi_fwd', "{} {}".format(node_name, ...<3 lines>... ), object_hook=c_common.as_wazuh_object) File "/usr/lib/python3.14/json/__init__.py", line 365, in loads return cls(**kw).decode(s) ~~~~~~~~~~~~~~~~^^^ File "/usr/lib/python3.14/json/decoder.py", line 345, in decode obj, end = self.raw_decode(s, idx=_w(s, 0).end()) ~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^ File "/usr/lib/python3.14/json/decoder.py", line 361, in raw_decode obj, end = self.scan_once(s, idx) ~~~~~~~~~~~~~~^^^^^^^^ File "/workspace/bundle/repro/worktrees/fixed/framework/wazuh/core/cluster/common.py", line 1943, in as_wazuh_object return getattr(wresults, wazuh_result['__class__']).decode_json(wazuh_result['__object__']) ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "/workspace/bundle/repro/worktrees/fixed/framework/wazuh/core/results.py", line 616, in decode_json raise wexception.WazuhInternalError(1000, extra_message=f"Invalid sort_casting type '{type_name}'. " f"Allowed types: {', '.join(sorted(ALLOWED_TYPES))}") wazuh.core.exception.WazuhInternalError: Error 1000 - Wazuh Internal Error: Invalid sort_casting type 'exec'. Allowed types: bool, float, int, str 2026-08-12T14:00:11Z MASTER_DAPI_RESULT type=WazuhInternalError repr={'type': 'about:blank', 'title': 'Wazuh Internal Error', 'code': 1000, 'extra_message': "Invalid sort_casting type 'exec'. Allowed types: bool, float, int, str", 'extra_remediation': None, 'cmd_error': False, 'dapi_errors': {'master01': {'error': "Wazuh Internal Error: Invalid sort_casting type 'exec'. Allowed types: bool, float, int, str", 'logfile': None}}} 2026-08-12T14:00:11Z MARKER_CHECK path=/workspace/bundle/repro/markers/product_marker_fixed_2.txt present=False content=None DEBUG:wazuh:Disconnected worker01. INFO:wazuh:Cancelling pending tasks. DEBUG:wazuh:Removing '/workspace/bundle/repro/worktrees/fixed/queue/cluster/worker01'. DEBUG:wazuh:Removed '/workspace/bundle/repro/worktrees/fixed/queue/cluster/worker01'. 2026-08-12T14:00:11Z OBSERVATION_JSON path=/workspace/bundle/repro/observations/product_fixed_2.json expected_behavior_observed=True rc=0 2026-08-12T14:00:11Z ATTEMPT_END role=fixed attempt=2 rc=0