brian
01/19/2022, 7:57 PMTrigger was "all_successful" but some of the upstream tasks failed.
but all the upstream tasks were successful. Am I missing something?Kevin Kho
brian
01/19/2022, 7:59 PMKevin Kho
brian
01/19/2022, 8:03 PMKevin Kho
Anna Geller
brian
01/19/2022, 11:06 PMAnna Geller
brian
01/19/2022, 11:54 PMKevin Kho
brian
01/21/2022, 8:25 PMprefect register
and have failOnStderr set to true
(which I don’t really want to change)
I now get a warning on stderr that looks like this
/Users/brian.sorahan/Library/Python/3.9/lib/python/site-packages/prefect/storage/base.py:154: UserWarning: Task <Task: Bar> has retry settings but some upstream dependencies do not have result types. See <https://docs.prefect.io/core/concepts/results.html> for more details.
_healthcheck.result_check(self._flows.values(), quiet=True) # type: ignore
This is actually me calling register from my laptop, but it’s the same warning we get on azure pipelines.
The script I’m trying to register is a small toy script that reproduces the warning.
The list_task
in this script is my workaround for the implicit List task issue we were discussing above, maybe I’m doing that wrong?Kevin Kho
brian
01/21/2022, 8:41 PMKevin Kho
list_task
is something like:
@task
def list_task():
return 2
and then
bar_task = bar(host_name, list_task())
The error makes sense since the retry will grab the output of the last time from its result (especially if Restarting as failed flow run)brian
01/21/2022, 11:37 PMKevin Kho