jaehoon
05/20/2021, 1:30 PMKevin Kho
05/20/2021, 2:02 PMjaehoon
05/21/2021, 4:53 AMfrom prefect import Flow, task, Parameter, Task
from prefect.tasks.prefect import StartFlowRun
from PrefectLogger import logger
flow_run = StartFlowRun(flow_name='inner-test-flow', project_name='pipeline')
class Dummy(Task):
def run(self):
return dict(x='1')
dummy = Dummy(name = 'dummy')
def registeration():
with Flow("admin-flow") as flow:
flow_run.set_upstream(dummy, key='parameters')
flow.register(project_name='pipeline')
@task
def logging(x):
<http://logger.info|logger.info>(x)
def register_test2():
with Flow('inner-test-flow') as flow:
x = Parameter('x', '0')
logging(x)
flow.register(project_name='pipeline')
if __name__ == '__main__':
registeration()
register_test2()
# run_tasks()
Kevin Kho
05/21/2021, 12:23 PMflow_run.set_upstream(dummy, key='parameters')
. dummy is still a task but hasn’t been used. Can you try something like this?class Dummy(Task):
def run(self):
return dict(x='1')
dummy = Dummy(name = 'dummy')
def registeration():
with Flow("admin-flow") as flow:
a = dummy()
b = flow_run()
b.set_upstream(a)
flow.register(project_name='pipeline')
jaehoon
05/24/2021, 2:38 AMKevin Kho
05/24/2021, 4:04 AM