Margaret Walter
10/21/2021, 5:36 PMJacob Bedard
10/21/2021, 6:02 PMJacob Bedard
10/21/2021, 6:03 PMJacob Bedard
10/21/2021, 6:03 PMWilliam Jamir
10/21/2021, 6:51 PMAqib Fayyaz
10/21/2021, 9:01 PMprefect agent kubernetes install -k API_KEY | kubectl apply --namespace=my-namespace -f -
this command successfully creates the deployment and referrs to default prefect image so the question is how can i use my code with it?Tony Yun
10/21/2021, 9:04 PMhaf
10/21/2021, 9:58 PMFailed 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}}}]
William Grim
10/21/2021, 10:36 PMprefect get logs --id uuid_of_that_flow
, it gets killed with no logs retrieved.
Is there another place to go look for logs?Tony Yun
10/21/2021, 10:46 PMQueued
with just one that task running. Only if I increase the limit to 2 it will start running. It looks a bug to me:Maria
10/21/2021, 11:05 PMAn error occurred (ClientException) when calling the RegisterTaskDefinition operation: Too many concurrent attempts to create a new revision of the specified family.
and I'm aware there is open github issue (https://github.com/PrefectHQ/prefect/issues/4402). We did adjust params as recommended but it still happens. I want to be able to restart the flow but cannot use task retry feature as no tasks have been started (it is the only log line I see and there is no start time for the flow ):Adam Everington
10/22/2021, 7:57 AMEddie Atkinson
10/22/2021, 9:12 AMgraphql-code-generator
but that hasn’t worked so farhaf
10/22/2021, 10:50 AMAdrien B
10/22/2021, 12:32 PMToprak Nihat Deniz Öztürk
10/22/2021, 1:50 PMf_run = flow.run
method and access the results with f_run.results[df].result
.Thomas Furmston
10/22/2021, 3:04 PMJoão Luiz Carabetta
10/22/2021, 3:57 PMstate = my_favorite_function()
Sahil Chopra
10/22/2021, 5:15 PMEmailTask
what is the EMAIL_USERNAME
and EMAIL_PASSWORD
used for? Are the notifications shipped from this email? Is this required, or is it possible to use the default notifications@prefect.io email address shown in the class definition?Hugo Kitano
10/22/2021, 5:28 PMquery {
flow_run(where: {name: {_eq: "woodoo-leopard"}}) {
id
state
start_time
}
}
Erik Nilsson
10/22/2021, 5:55 PMGiovanni Giacco
10/22/2021, 6:03 PMCharles Liu
10/22/2021, 6:29 PMJacob Goldberg
10/22/2021, 6:53 PMValueError: Local Secret "SLACK_WEBHOOK_URL" was not found.
Kevin Kho
10/22/2021, 7:56 PMhere▾
Tony Yun
10/22/2021, 8:01 PMDylan
10/22/2021, 8:06 PMhttps://youtu.be/etktOF6Wb4o▾
Abhas P
10/22/2021, 8:09 PMJoe Still
10/22/2021, 9:04 PMMatt Alhonte
10/22/2021, 11:17 PMif notebook_name in list_of_notebooks:
run_notebook(notebook_name)
else:
print("skipped")
How do I do that with the StartFlowRun
task? Should I subclass it and replace the existing .run()
method?Matt Alhonte
10/22/2021, 11:17 PMif notebook_name in list_of_notebooks:
run_notebook(notebook_name)
else:
print("skipped")
How do I do that with the StartFlowRun
task? Should I subclass it and replace the existing .run()
method?Kevin Kho
10/22/2021, 11:26 PMStartFlowRun
call if it fulfills the condition.Matt Alhonte
10/22/2021, 11:29 PM.run()
fn to a different name (let's say .execute_flow
, and then have the new .run()
as something like if notebook_name in list_of_notebooks: self.execute_flow()
?Kevin Kho
10/23/2021, 1:48 AMsuper.run()
to call the ShellTask run()