Nicholas Roberson
05/05/2023, 6:05 PM@task
using remote.execute
with the arg options=Options(labels=Labels({"test_label": "test_value"}))
and I cannot seem to get that label to attach to the pod in kubernetes, however this same setup works when I call this using a @workflow
and I can see my "test_label"
label added to all pods spun up by the workflow, is this to be expected? If so is there a way to attach pod labels when running remote.execute
just on a @task
?Yee
Nicholas Roberson
05/05/2023, 6:15 PMFlyteRemote(...).execute(example_task, options=options, ...)
Yee
Nicholas Roberson
05/05/2023, 6:23 PM@dynamic
tasks.David Espejo (he/him)
05/05/2023, 7:26 PMNicholas Roberson
05/05/2023, 7:27 PMYee
Nicholas Roberson
05/08/2023, 3:09 PMremote.execute
on
import logging
from flytekit import dynamic, task, workflow
@task
def my_task(input: str) -> str:
return input
type()
on the task when I run it from my local I do get flytekit.core.python_function_task.PythonFunctionTask
, will try triggering it from a remote workflow to see if the behavior changes.Yee
remote.fetch_task
? Or are you doing @task
?Nicholas Roberson
05/08/2023, 6:30 PMYee
Nicholas Roberson
05/08/2023, 9:57 PM