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
04/06/2022, 2:45 PMKonstantin
04/06/2022, 2:49 PMKevin Kho
04/06/2022, 2:57 PMKonstantin
04/06/2022, 3:09 PMKevin Kho
04/06/2022, 3:11 PMKonstantin
04/06/2022, 3:15 PMKevin Kho
04/06/2022, 3:28 PMKonstantin
04/06/2022, 6:09 PMKevin Kho
04/06/2022, 7:42 PMKonstantin
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
04/06/2022, 11:10 PMKonstantin
04/07/2022, 5:19 AMKevin Kho
04/07/2022, 5:29 AMKonstantin
04/07/2022, 2:30 PMKevin Kho
04/07/2022, 2:33 PMKonstantin
04/08/2022, 1:01 PMAnna Geller
04/08/2022, 1:57 PMKonstantin
04/08/2022, 1:58 PMAnna Geller
04/08/2022, 2:03 PMKonstantin
04/08/2022, 2:59 PMKevin Kho
04/08/2022, 3:26 PMflow.run_config = KubernetesRun(...,env={"PREFECT_CLOUD__HEARTBEAT_MODE": "thread"})
Konstantin
04/09/2022, 4:17 PM