Skip to content

Instantly share code, notes, and snippets.

@anna-geller
Created October 18, 2021 13:25
Show Gist options
  • Save anna-geller/fd8d850f643b59b87c063581926d26db to your computer and use it in GitHub Desktop.
Save anna-geller/fd8d850f643b59b87c063581926d26db to your computer and use it in GitHub Desktop.
from prefect import Flow, Parameter, task
@task(log_stdout=True)
def test_parameter_value(user_input: str):
print(f"Got parameter value: {user_input}")
with Flow('child') as flow:
num_days_parameter = Parameter('num_days', required=True)
num_back_fill_days_parameter = Parameter('num_back_fill_days', required=True)
end_date_parameter = Parameter('end_date', required=True)
test_parameter_value(num_days_parameter)
test_parameter_value(num_back_fill_days_parameter)
test_parameter_value(end_date_parameter)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment