Skip to content

taps.executor.globus

taps/executor/globus.py

GlobusComputeConfig

Bases: ExecutorConfig

Globus Compute Executor plugin configuration.

Attributes:

  • endpoint (str) –

    Globus Compute endpoint UUID.

  • batch_size (int) –

    Maximum number of tasks to coalesce before submitting.

get_executor() 

get_executor() -> FutureDependencyExecutor

Create an executor instance from the config.

Source code in taps/executor/globus.py 
29
30
31
32
33
34
35
def get_executor(self) -> FutureDependencyExecutor:
    """Create an executor instance from the config."""
    executor = globus_compute_sdk.Executor(
        self.endpoint,
        batch_size=self.batch_size,
    )
    return FutureDependencyExecutor(executor)