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?Martin T
01/04/2022, 7:30 AMNoah Holm
01/04/2022, 9:52 AMLucas Hosoya
01/04/2022, 12:49 PMstate.Cancelling
and state.Cancelled
as True
, but none of them occurs.
It only register as Cancelling
or Cancelled
when I put the flow to the State (UI) as Cancelled.
Another weird fact is if I put the State as Cancelled, my tasks keeps running until it finishes (either in fail or succeed).
I'm currently working on State handlers, how can I be sure that I'm cancelling my flow runs and consequently my tasks for that flow run?Thomas Hoeck
01/04/2022, 1:52 PMScheduled
to Cancelled
without pressing cancel in the UI. By the looks of the following query the Flow Run was cancelled because a new version of the Flow was released (which archived the old flow). Is this expected behavior?Rob Douglas
01/04/2022, 2:00 PMPhilip MacMenamin
01/04/2022, 3:47 PMl1 = [a, b, c]
and I generate l2 = task_name.map(l1)
, can I trust that element 0 in l2
derives from element 0 from l1
?Theo Platt
01/04/2022, 4:22 PM