-
I try get parameters: from prefect import flow, task
from pprint import pprint
def _log_scrapy_load(task: 'Task', task_run: 'TaskRun', state: 'State'):
print(f'{task.name} <- {task_run.task_inputs}')
@task(on_failure=[_log_scrapy_load],)
def scrapy_site(feed_prefix:str):
assert False
@flow
def flow_getsite():
feed_prefix = f'{SITE_NAME}-'
scrapy_site.submit(feed_prefix).result() output:
How to get real data from task parameters? |
Beta Was this translation helpful? Give feedback.
Answered by
zanieb
Apr 10, 2023
Replies: 1 comment 2 replies
-
These are available at |
Beta Was this translation helpful? Give feedback.
2 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
@tonal that's not the correct
task_run
— use the one atprefect.runtime.task_run
.