Hi, community, does the new PR about `execution cl...
# ask-the-community
l
Hi, community, does the new PR about
execution cluster label
cause any bug? I can't use
pyflyte run --remote
to execute my workflow. Or is there any setup I've missed? flyte PR: https://github.com/flyteorg/flyte/pull/5431 flytekit PR: https://github.com/flyteorg/flytekit/pull/2422 Note:
pyflyte register
works.
Here's my example.
Copy code
from flytekit.loggers import logger
from flytekit import ImageSpec, Secret, task, workflow
from flytekit import Resources

@task
def say_hello() -> str:
    return "hello"

@workflow
def wf() -> str:
    return say_hello()
k
could you use
pyflyte --vv run --remote ..
to run it again, and share the output?
l
No prob
Copy code
(dev) future@outlier ~ % pyflyte --verbose run --remote task_example.py wf

Running Execution on Remote.
Verbose mode on
╭────────────────────────────────────────── Traceback (most recent call last) ──────────────────────────────────────────╮
│ /Users/future-outlier/miniconda3/envs/dev/bin/pyflyte:8 in <module>                                                   │
│                                                                                                                       │
│ ❱ 8 │   sys.exit(main())                                                                                              │
│                                                                                                                       │
│ /Users/future-outlier/miniconda3/envs/dev/lib/python3.9/site-packages/click/core.py:1157 in __call__                  │
│                                                                                                                       │
│ ❱ 1157 │   │   return self.main(*args, **kwargs)                                                                      │
│                                                                                                                       │
│ /Users/future-outlier/miniconda3/envs/dev/lib/python3.9/site-packages/rich_click/rich_command.py:126 in main          │
│                                                                                                                       │
│ ❱ 126 │   │   │   │   │   rv = self.invoke(ctx)                                                                       │
│                                                                                                                       │
│ /Users/future-outlier/code/flytekit/flytekit/clis/sdk_in_container/utils.py:148 in invoke                             │
│                                                                                                                       │
│ ❱ 148 │   │   │   │   raise e                                                                                         │
│                                                                                                                       │
│ /Users/future-outlier/code/flytekit/flytekit/clis/sdk_in_container/utils.py:142 in invoke                             │
│                                                                                                                       │
│ ❱ 142 │   │   │   return super().invoke(ctx)                                                                          │
│                                                                                                                       │
│ /Users/future-outlier/miniconda3/envs/dev/lib/python3.9/site-packages/click/core.py:1688 in invoke                    │
│                                                                                                                       │
│ ❱ 1688 │   │   │   │   │   return _process_result(sub_ctx.command.invoke(sub_ctx))                                    │
│                                                                                                                       │
│ /Users/future-outlier/miniconda3/envs/dev/lib/python3.9/site-packages/click/core.py:1688 in invoke                    │
│                                                                                                                       │
│ ❱ 1688 │   │   │   │   │   return _process_result(sub_ctx.command.invoke(sub_ctx))                                    │
│                                                                                                                       │
│ /Users/future-outlier/miniconda3/envs/dev/lib/python3.9/site-packages/click/core.py:1688 in invoke                    │
│                                                                                                                       │
│ ❱ 1688 │   │   │   │   │   return _process_result(sub_ctx.command.invoke(sub_ctx))                                    │
│                                                                                                                       │
│ /Users/future-outlier/miniconda3/envs/dev/lib/python3.9/site-packages/click/core.py:1434 in invoke                    │
│                                                                                                                       │
│ ❱ 1434 │   │   │   return ctx.invoke(self.callback, **ctx.params)                                                     │
│                                                                                                                       │
│ /Users/future-outlier/miniconda3/envs/dev/lib/python3.9/site-packages/click/core.py:783 in invoke                     │
│                                                                                                                       │
│ ❱  783 │   │   │   │   return __callback(*args, **kwargs)                                                             │
│                                                                                                                       │
│ /Users/future-outlier/code/flytekit/flytekit/clis/sdk_in_container/run.py:580 in _run                                 │
│                                                                                                                       │
│ ❱ 580 │   │   │   │   run_remote(                                                                                     │
│                                                                                                                       │
│ /Users/future-outlier/code/flytekit/flytekit/clis/sdk_in_container/run.py:448 in run_remote                           │
│                                                                                                                       │
│ ❱ 448 │   execution = remote.execute(                                                                                 │
│                                                                                                                       │
│ /Users/future-outlier/code/flytekit/flytekit/remote/remote.py:1337 in execute                                         │
│                                                                                                                       │
│ ❱ 1337 │   │   │   return self.execute_remote_wf(                                                                     │
│                                                                                                                       │
│ /Users/future-outlier/code/flytekit/flytekit/remote/remote.py:1518 in execute_remote_wf                               │
│                                                                                                                       │
│ ❱ 1518 │   │   return self.execute_remote_task_lp(                                                                    │
│                                                                                                                       │
│ /Users/future-outlier/code/flytekit/flytekit/remote/remote.py:1479 in execute_remote_task_lp                          │
│                                                                                                                       │
│ ❱ 1479 │   │   return self._execute(                                                                                  │
╰───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯
TypeError: _execute() got an unexpected keyword argument 'execution_cluster_label'
Verbose Message
k
l
My environment is as follow.
Copy code
flyte version: master branch with latest version
flytekit version: master branch with latest version
flyteidl version: master branch with latest version
Copy code
which pyflyte
/Users/future-outlier/miniconda3/envs/dev/bin/pyflyte
d
@L godlike is this still not working for you?
l
It works now
Thank you