Abdullah Mobeen
08/09/2022, 1:28 PM@task(task_config=MyContainerExecutionTask(
plugin_specific_config_a=...,
plugin_specific_config_b=...,
...
))
def foo(...) -> ...:
...
And
query_task = SnowflakeTask(
query="Select * from x where x.time < {{.inputs.time}}",
inputs=kwtypes(time=datetime),
output_schema_type=pandas.DataFrame,
)
@workflow
def my_wf(t: datetime) -> ...:
df = query_task(time=t)
return process(df=df)
I'm trying to find examples/tutorials/how-tos on the first approach, but I can't find any. Can someone point me to an example?Ketan (kumare3)
Abdullah Mobeen
08/09/2022, 1:51 PMKetan (kumare3)
Abdullah Mobeen
08/09/2022, 2:14 PMKetan (kumare3)
Babis Kiosidis
08/09/2022, 3:12 PM