Skip to content

[bug] get_item_from_future() is not supported for ClusterExecutors #909

@jan-janssen

Description

@jan-janssen

Example:

from executorlib import get_item_from_future
from executorlib.api import TestClusterExecutor

def return_dict(i):
    return {"i": i}

with TestClusterExecutor() as exe:
    f1 = exe.submit(return_dict, i=1)
    f2 = exe.submit(return_dict, i=get_item_from_future(f1, key="i"))
    print(f2.result())

The same example works fine with the SingleNodeExecutor.

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions