Peyton Runyan
02/16/2021, 8:21 PMsql_task = SqlServerFetch(
db_name=prefect.config.sql_server.database,
user=prefect.config.sql_server.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,
)
with Flow("config_flow") as f:
mode = Parameter("Mode", default="dev")
password_var = set_creds(mode)
password_task = EnvVarSecret()
password = password_task(password_var)
s = sql_task(password=password)
v = view_sql(sql_task)
Jim Crist-Harif
02/16/2021, 8:22 PMs
to view_sql
, not sql_task
.Peyton Runyan
02/16/2021, 8:25 PMJim Crist-Harif
02/16/2021, 8:26 PM