Hi, community, does the new PR about `execution cl...
# flyte-supportd
damp-lion-88352
06/22/2024, 4:16 PMHi, community, does the new PR about
execution cluster labelpyflyte run --remotepyflyte register✅ 1
damp-lion-88352
06/22/2024, 4:16 PMHere'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()g
glamorous-carpet-83516
06/22/2024, 5:59 PMcould you use
pyflyte --vv run --remote ..d
damp-lion-88352
06/22/2024, 10:32 PMNo prob
damp-lion-88352
06/23/2024, 12:08 AM 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'damp-lion-88352
06/23/2024, 12:09 AMVerbose Message
g
glamorous-carpet-83516
06/23/2024, 12:14 AMdoes your
_executeexecution_cluster_labeld
damp-lion-88352
06/23/2024, 12:55 AMMy 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 versiondamp-lion-88352
06/23/2024, 12:57 AM Copy code
which pyflyte
/Users/future-outlier/miniconda3/envs/dev/bin/pyflytea
average-finland-92144
06/24/2024, 3:59 PM@damp-lion-88352 is this still not working for you?
d
damp-lion-88352
06/24/2024, 10:01 PMIt works now
damp-lion-88352
06/24/2024, 10:01 PMThank you
4 Views