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 inputquick-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