Skip to content

taps.executor.globus

GlobusComputeConfig

Bases: ExecutorConfig

Globus Compute Executor plugin configuration.

Parameters:

  • name (Literal['globus'], default: 'globus' ) –

    Executor name.

  • endpoint (str) –

    Globus Compute Endpoint UUID.

  • batch_size (int, default: 128 ) –

    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 
24
25
26
27
28
29
30
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)