quick-barista-52015
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
?quick-barista-52015
05/05/2023, 6:09 PMthankful-minister-83577
quick-barista-52015
05/05/2023, 6:15 PMFlyteRemote(...).execute(example_task, options=options, ...)
thankful-minister-83577
quick-barista-52015
05/05/2023, 6:23 PMquick-barista-52015
05/05/2023, 6:23 PMquick-barista-52015
05/05/2023, 6:26 PM@dynamic
tasks.average-finland-92144
05/05/2023, 7:26 PMquick-barista-52015
05/05/2023, 7:27 PMquick-barista-52015
05/05/2023, 7:28 PMthankful-minister-83577
thankful-minister-83577
thankful-minister-83577
thankful-minister-83577
thankful-minister-83577
quick-barista-52015
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
quick-barista-52015
05/08/2023, 3:21 PMtype()
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.thankful-minister-83577
thankful-minister-83577
remote.fetch_task
? Or are you doing @task
?quick-barista-52015
05/08/2023, 6:30 PMthankful-minister-83577
quick-barista-52015
05/08/2023, 9:57 PM