Shivam Bhatia
01/11/2022, 10:44 AMFailed to retrieve task state with error: ClientError([{'path': ['get_or_create_task_run_info'], 'message': 'Expected type UUID!, found ""; Could not parse UUID: ', 'extensions': {'code': 'INTERNAL_SERVER_ERROR', 'exception': {'message': 'Expected type UUID!, found ""; Could not parse UUID: ', 'locations': [{'line': 2, 'column': 101}], 'path': None}}}])
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/prefect/engine/cloud/task_runner.py", line 154, in initialize_run
task_run_info = self.client.get_task_run_info(
File "/usr/local/lib/python3.8/site-packages/prefect/client/client.py", line 1798, in get_task_run_info
result = self.graphql(mutation) # type: Any
File "/usr/local/lib/python3.8/site-packages/prefect/client/client.py", line 569, in graphql
raise ClientError(result["errors"])
prefect.exceptions.ClientError: [{'path': ['get_or_create_task_run_info'], 'message': 'Expected type UUID!, found ""; Could not parse UUID: ', 'extensions': {'code': 'INTERNAL_SERVER_ERROR', 'exception': {'message': 'Expected type UUID!, found ""; Could not parse UUID: ', 'locations': [{'line': 2, 'column': 101}], 'path': None}}}]
Anna Geller
Shivam Bhatia
01/13/2022, 10:39 AMAnna Geller
Anna Geller
Shivam Bhatia
01/13/2022, 12:10 PMfrom flow_file import flow
from prefect.run_configs import VertexRun
from prefect.storage import GitHub
def register(project_name):
flow.storage = GitHub(
repo="{{repo name}}",
path="{{file in repo}}",
access_token_secret="GITHUB_ACCESS_TOKEN"
)
flow.run_config = VertexRun(
image="{{image path (on dockerhub)}}",
machine_type="e2-highmem-8",
labels=["dev"]
)
flow.register(project_name)
Shivam Bhatia
01/13/2022, 12:11 PMShivam Bhatia
01/13/2022, 12:13 PMAnna Geller
Shivam Bhatia
01/13/2022, 12:17 PMresponse = client.graphql(
"""mutation {
create_flow_run(input: {
flow_id: \"""" + flow_id + """\",
parameters: "{\\\"pipeline_name\\\": \\\"""" + pipeline_name + """\\\", \\\"email\\\": \\\"""" + email + """\\\"}"
}) {
id
}
}
""")
Shivam Bhatia
01/13/2022, 12:17 PMwith Flow("dask_stage_flow") as flow:
pipeline_name = Parameter('pipeline_name')
email = Parameter('email')
pipeline_config, src_config, dest_config = get_config(pipeline_name, email)
Anna Geller
prefect register --project yourprojectname -p your_flow.py --force
I’m asking this because reregistration solves this error in 95% of use cases I’ve seenShivam Bhatia
01/13/2022, 12:19 PMAnna Geller
@task(nout=3)
?Shivam Bhatia
01/13/2022, 12:21 PMAnna Geller
prefect register --project yourprojectname -p your_flow.py --force
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
Powered by