Ramzi A
12/29/2021, 2:35 AMAqib Fayyaz
12/29/2021, 7:27 AMMichal Baumgartner
12/29/2021, 2:29 PMCarlos Paiva
12/29/2021, 5:41 PMwith Flow(name="name", storage=storage, run_config=run_config) as flow:
# Pipeline parameters
event = Parameter('event', required=True, default={})
x = event.get("body", None)
How can I access the dictionary data?
I am getting AttributeError: 'Parameter' object has no attribute 'get'
Enda Peng
12/30/2021, 1:46 AM~/.prefect/config.toml
deprecated? I tried with prefect agent local start -t <my-token>
which succeeds, however, after I save it under config.toml and restart without -t
, it complains about missing API key, this is my config.toml file
[xxx]# cat ~/.prefect/config.toml
[cloud]
api_key = "*******"
Anh Nguyen
12/30/2021, 4:10 PMSean Leakehe
12/30/2021, 4:32 PMUnixHTTPConnectionPool
errors in Prefect Cloud? These happen seemingly at random. I have this particular flow set to retry 3 times and it I got this on all 3 retries.chelseatroy
12/30/2021, 5:17 PMChristoph Deil
12/30/2021, 5:21 PMTom Shaffner
12/30/2021, 8:38 PMAn Hoang
01/02/2022, 1:24 AMtask_run_name
when templated with input names can be very helpful in debugging mapped tasks. Are they only available on Prefect backend (Cloud and Server) and not Core?
If I'm doing local debugging with flow_result = flow.run()
, let's say I have a flow with task_a
mapped 1000 times and task_a[25]
failed but the other indices succeed. What's the quickest way to find out which input caused it to fail? I don't think I can access the result of flow_result.result[task_a].result[25]
Fina Silva-Santisteban
01/02/2022, 7:28 PMTom Klein
01/02/2022, 7:55 PMservice account
but it seems insufficient and we noticed some warning in the docs about that but couldn't really decipher what it would mean for us since we don't use these methods to define permissions:John Muehlhausen
01/02/2022, 11:06 PMOvo Ojameruaye
01/03/2022, 6:35 AMjcozar
01/03/2022, 7:57 AMprefecthq/prefect:0.15.11-python3.8
), but I am using python 3.9 to register the flow to prefect cloud. It fails because I am using different python versions. Could you please clarify me how it works? Thank you very much!Ido Slonimsky
01/03/2022, 7:58 AMbotocore.errorfactory.InvalidParameterException: An error occurred (InvalidParameterException) when calling the RunTask operation: TaskDefinition is inactive
after this:
Creating a new Dask cluster with `dask_cloudprovider.aws.ecs.FargateCluster`...
In the run config, both when it succeeds and when it fails the task_definition is null, and all the other settings are the same, has anybody encountered a similar issue and has any idea what could go wrong?Suresh R
01/03/2022, 8:01 AMKostas Chalikias
01/03/2022, 8:06 AMAndrey Vinogradov
01/03/2022, 10:25 AMIsara De Silva
01/03/2022, 11:37 AMThomas Opsomer
01/03/2022, 3:31 PMKevin Weiler
01/03/2022, 4:01 PMAn Hoang
01/03/2022, 4:34 PMConstantino Schillebeeckx
01/03/2022, 5:37 PMAn Hoang
01/03/2022, 6:06 PMset_reference_task()
but not set_terminal_task()
. I'm trying to debug by stopping the flow early and inspect the resultsdammy arinde
01/03/2022, 6:10 PMTypeError: 'Checkpoint' object is not subscriptable
Chris McLaughlin
01/03/2022, 8:40 PMJosh
01/03/2022, 9:07 PMSam Werbalowsky
01/03/2022, 10:26 PMval = Parameter("param", False):
case(val, True):
do_stuff()
case(val, False):
dont_do_stuff()
If my paramter is an actual value, i.e. “value”, it skips both because it’s neither True nor False. So I’m left to make another task to check the value. Is this correct?Sam Werbalowsky
01/03/2022, 10:26 PMval = Parameter("param", False):
case(val, True):
do_stuff()
case(val, False):
dont_do_stuff()
If my paramter is an actual value, i.e. “value”, it skips both because it’s neither True nor False. So I’m left to make another task to check the value. Is this correct?[2022-01-03 17:21:27-0500] INFO - prefect.TaskRunner | SKIP signal raised: SKIP('Provided value "VALUE" did not match "False"')
[2022-01-03 17:21:27-0500] INFO - prefect.TaskRunner | Task 'case(True)': Starting task run...
[2022-01-03 17:21:27-0500] INFO - prefect.TaskRunner | Task 'case(False)': Finished task run for task with final state: 'Skipped'
[2022-01-03 17:21:27-0500] INFO - prefect.TaskRunner | SKIP signal raised: SKIP('Provided value "VALUE" did not match "True"')
Kevin Kho
01/03/2022, 10:35 PMcase
is not limited to True or False. It can be a constant number for example:
from prefect import Flow, task, case, Parameter
import prefect
@task
def do_something():
<http://prefect.context.logger.info|prefect.context.logger.info>("this ran")
return 1
with Flow("conditional-branches") as flow:
cond = Parameter("cond", 3)
with case(cond, 3):
val = do_something()
flow.run()
Sam Werbalowsky
01/03/2022, 10:38 PMKevin Kho
01/03/2022, 10:39 PM