Konstantin
04/06/2022, 2:39 PMFailed to set task state with error: ClientError([{'message': 'State update failed for task run ID 7f12b68e-3a3b-45f6-9231-283d30105595: provided a running state but associated flow run 2582c918-369e-4422-ade8-811843f495cf is not in a running state.', 'locations': [{'line': 2, 'column': 5}], 'path': ['set_task_run_states'], 'extensions': {'code': 'INTERNAL_SERVER_ERROR', 'exception': {'message': 'State update failed for task run ID 7f12b68e-3a3b-45f6-9231-283d30105595: provided a running state but associated flow run 2582c918-369e-4422-ade8-811843f495cf is not in a running state.'}}}])
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/prefect/engine/cloud/task_runner.py", line 91, in call_runner_target_handlers
state = self.client.set_task_run_state(
File "/usr/local/lib/python3.9/site-packages/prefect/client/client.py", line 1839, in set_task_run_state
result = self.graphql(
File "/usr/local/lib/python3.9/site-packages/prefect/client/client.py", line 563, in graphql
raise ClientError(result["errors"])
prefect.exceptions.ClientError: [{'message': 'State update failed for task run ID 7f12b68e-3a3b-45f6-9231-283d30105595: provided a running state but associated flow run 2582c918-369e-4422-ade8-811843f495cf is not in a running state.', 'locations': [{'line': 2, 'column': 5}], 'path': ['set_task_run_states'], 'extensions': {'code': 'INTERNAL_SERVER_ERROR', 'exception': {'message': 'State update failed for task run ID 7f12b68e-3a3b-45f6-9231-283d30105595: provided a running state but associated flow run 2582c918-369e-4422-ade8-811843f495cf is not in a running state.'}}}]
There is a problem with launching tasks in Prefect, on the screenshots, the last two unsuccessful launches returned an error (described above), the last launch was performed manually, ended in success.Kevin Kho
Konstantin
04/06/2022, 2:49 PMKevin Kho
Konstantin
04/06/2022, 3:09 PMKevin Kho
Konstantin
04/06/2022, 3:15 PMKevin Kho
Konstantin
04/06/2022, 6:09 PMKevin Kho
Konstantin
04/06/2022, 9:31 PMCreate Project ads_importing if not exist:
23ads_importing created
24Create Project clickhouse if not exist:
25clickhouse created
26Register file flows/clickhouse/file.py or update flow:
27Collecting flows...
28Processing 'flows/clickhouse/file.py':
29 Building `GitLab` storage...
30 Registering 'import_data from clickhouse in DWH'... Done
31 βββ ID: 8359eee7-4bb6-4271-8a77-xxxxxxxxxxxx
32 βββ Version: 1
33======================== 1 registered ========================
Kevin Kho
Konstantin
04/07/2022, 5:19 AMKevin Kho
Konstantin
04/07/2022, 2:30 PMKevin Kho
Konstantin
04/08/2022, 1:01 PMAnna Geller
Konstantin
04/08/2022, 1:58 PMAnna Geller
Konstantin
04/08/2022, 2:59 PMKevin Kho
flow.run_config = KubernetesRun(...,env={"PREFECT_CLOUD__HEARTBEAT_MODE": "thread"})
Konstantin
04/09/2022, 4:17 PM