Mateusz Pazdzior
10/18/2022, 2:54 PM[2022-10-18 14:42:58,717] ERROR - xyz| Failed to query for flow run metadata
Oct 18 16:42:58 datalake01 bash[17042]: Traceback (most recent call last):
Oct 18 16:42:58 datalake01 bash[17042]: File "/usr/local/lib/python3.8/dist-packages/prefect/agent/agent.py", line 331, in _submit_deploy_flow_run_jobs
Oct 18 16:42:58 datalake01 bash[17042]: flow_runs = self._get_flow_run_metadata(flow_run_ids)
Oct 18 16:42:58 datalake01 bash[17042]: File "/usr/local/lib/python3.8/dist-packages/prefect/agent/agent.py", line 691, in _get_flow_run_metadata
Oct 18 16:42:58 datalake01 bash[17042]: result = self.client.graphql(query)
Oct 18 16:42:58 datalake01 bash[17042]: File "/usr/local/lib/python3.8/dist-packages/prefect/client/client.py", line 570, in graphql
Oct 18 16:42:58 datalake01 bash[17042]: raise ClientError(result["errors"])
Oct 18 16:42:58 datalake01 bash[17042]: prefect.exceptions.ClientError: [{'path': ['flow_run', 0, 'id'], 'message': 'Cannot return null for non-nullable field flow_run.id.', 'extensions': {'code': 'INTERNAL_SERVER_ERROR'}}]
We tried to restart the agent service and rebuild the docker image but this zoombie is still running. We have the flow run id and when we query it the state is running. Do you have any idea how to kill the flow run? Its Prefect 1.
cc @Angelika TarnawaMason Menges
10/18/2022, 4:54 PMmutation setFlowRunStates($input: [set_flow_run_state_input!]!) {
set_flow_run_states(input: {states: $input}) {
states {
id
__typename
}
__typename
}
}
with this input in the query variables
{
"input": {
"flow_run_id": "flow_run_id",
"version": 1,
"state": {
"type": "Cancelled",
"message": "marked task run as Cancelled because \"because\""
}
}
}
Here's a screenshot for reference, it's referencing task runs but the concept applies the same 😄 if that doesn't work you can send in a request to help@prefect.io 😄Mateusz Pazdzior
10/19/2022, 11:48 AMBianca Hoch
10/19/2022, 3:20 PM