Riley Hun
08/12/2020, 6:41 PMValueError: Task <Task: ThinkNumGetHistoryTask> has retry settings but some upstream dependencies do not have result types
Would anyone know how to address this error? I tried adding retry to all the tasks in the flow, but didn't seem to resolve the issue.token_task = ThinkNumGetTokenTask(
max_retries=3,
retry_delay=timedelta(seconds=10)
)
history_task = ThinkNumGetHistoryTask(
max_retries=3,
retry_delay=timedelta(seconds=10)
)
with Flow("thinknum-etl") as flow:
token = token_task(
version=version
)
history = history_task(
dataset_id=dataset_id,
version=version,
token=token
)
josh
08/12/2020, 6:45 PMRiley Hun
08/12/2020, 6:54 PMtoken_task = ThinkNumGetTokenTask(
max_retries=3,
retry_delay=timedelta(seconds=10),
result=GCSResult(bucket='prefect')
)
history_task = ThinkNumGetHistoryTask(
max_retries=3,
retry_delay=timedelta(seconds=10)
)
which I can confirm has resolved the aforementioned error.