https://flyte.org logo
a

Abdullah Mobeen

08/09/2022, 1:28 PM
Hi, I'm reading the Flyte documentation on extending a task. There are two ways listed.
Copy code
@task(task_config=MyContainerExecutionTask(
    plugin_specific_config_a=...,
    plugin_specific_config_b=...,
    ...
))
def foo(...) -> ...:
    ...
And
Copy code
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?
a

Abdullah Mobeen

08/09/2022, 1:51 PM
Thanks! I also found the AWS Batch example, which is closer to what I need
k

Ketan (kumare3)

08/09/2022, 2:01 PM
Fantastic
But AWS batch uses backend plugin
a

Abdullah Mobeen

08/09/2022, 2:14 PM
Yeah sorry, I realized my question isn't exactly what I was looking for. Still learning flyte 😅
k

Ketan (kumare3)

08/09/2022, 2:14 PM
No worries 😍
Welcome to the community
🙏 1
b

Babis Kiosidis

08/09/2022, 3:12 PM
Welcome Abdullah, we use backend plugins for some other tasks, it might work for you as well. can sync