Peyton Runyan
02/16/2021, 10:58 PMPeyton Runyan
02/16/2021, 10:58 PMwith Flow("config_flow") as f:
mode = Parameter("Mode", default="dev")
user, db, password_var = set_creds(mode)
print_task(user)
print_task(db)
print_task(password_var)
password_task = EnvVarSecret()
password = password_task(password_var)
# Get our database items
# thing = Parameter("thing", default=["Thing 1"])
# d = dog(thing)
sql_task = SqlServerFetch(
db_name=db,
user=user,
host=prefect.config.sql_server.server,
query=get_manual_override_rows,
fetch='many',
fetch_count=3,
result=result_formatter,
name="Database Query"
# commit: bool = False,
)
s = sql_task(password=password)
Peyton Runyan
02/16/2021, 10:59 PMPeyton Runyan
02/16/2021, 10:59 PMPeyton Runyan
02/16/2021, 11:00 PMAmanda Wee
02/16/2021, 11:20 PMpassword_task = EnvVarSecret()
password = password_task(password_var)
be:
password = EnvVarSecret(password_var)
?Chris White
## all task initializations / etc. go here
mode = Parameter("Mode", default="dev")
sql_task = SQLServer(...) # etc.
## all task _dependencies_ are set here
with Flow("config_flow") as f:
...
This should help you reason through issues like this more cleanlyPeyton Runyan
02/16/2021, 11:31 PMPeyton Runyan
02/16/2021, 11:52 PMChris White