API Reference

• Globus Compute Executor
  • Executor
    • Executor.endpoint_id
    • Executor.task_group_id
    • Executor.resource_specification
    • Executor.user_endpoint_config
    • Executor.amqp_port
    • Executor.serializer
    • Executor.result_serializers
    • Executor.register_function()
    • Executor.register_source_code()
    • Executor.submit()
    • Executor.submit_to_registered_function()
    • Executor.map()
    • Executor.reload_tasks()
    • Executor.shutdown()
    • Executor.get_worker_hardware_details()
  • ComputeFuture
    • ComputeFuture.task_id
• Globus Compute Client
  • Client
    • Client.version_check()
    • Client.logout()
    • Client.get_task()
    • Client.get_result()
    • Client.get_batch_result()
    • Client.run()
    • Client.create_batch()
    • Client.batch_run()
    • Client.register_endpoint()
    • Client.get_endpoint_status()
    • Client.get_endpoint_metadata()
    • Client.get_endpoints()
    • Client.register_function()
    • Client.register_source_code()
    • Client.get_function()
    • Client.get_allowed_functions()
    • Client.stop_endpoint()
    • Client.delete_endpoint()
    • Client.delete_function()
    • Client.get_worker_hardware_details()
  • Batch
    • Batch.add()
    • Batch.prepare()
  • UserRuntime
    • UserRuntime.PythonInfo
    • UserRuntime.PlatformInfo
• Globus Compute Serializer
  • ComputeSerializer
    • ComputeSerializer.serialize_from_list()
    • ComputeSerializer.serialize()
    • ComputeSerializer.deserialize()
    • ComputeSerializer.pack_buffers()
    • ComputeSerializer.unpack_buffers()
    • ComputeSerializer.unpack_and_deserialize()
    • ComputeSerializer.check_strategies()
    • ComputeSerializer.assert_deserializer_allowed()
  • Strategylike
  • AllowlistWildcard
    • AllowlistWildcard.CODE
    • AllowlistWildcard.DATA
  • DEFAULT_STRATEGY_CODE
  • DEFAULT_STRATEGY_DATA
• Serialization Strategies
  • SerializationStrategy
    • SerializationStrategy.identifier
    • SerializationStrategy.for_code
    • SerializationStrategy.serialize()
    • SerializationStrategy.deserialize()
    • SerializationStrategy.chomp()
  • ComboSerializationStrategy
  • AllCodeStrategies
    • AllCodeStrategies.identifier
    • AllCodeStrategies.for_code
  • AllDataStrategies
    • AllDataStrategies.identifier
    • AllDataStrategies.for_code
  • CombinedCode
    • CombinedCode.identifier
    • CombinedCode.for_code
    • CombinedCode.deserialize()
  • DillCode
    • DillCode.identifier
    • DillCode.for_code
  • DillCodeSource
    • DillCodeSource.identifier
    • DillCodeSource.for_code
  • DillCodeTextInspect
    • DillCodeTextInspect.identifier
    • DillCodeTextInspect.for_code
  • PureSourceDill
    • PureSourceDill.identifier
    • PureSourceDill.for_code
  • PureSourceTextInspect
    • PureSourceTextInspect.identifier
    • PureSourceTextInspect.for_code
  • DillDataBase64
    • DillDataBase64.identifier
    • DillDataBase64.for_code
  • JSONData
    • JSONData.identifier
    • JSONData.for_code
• Globus Compute Engine
  • GlobusComputeEngine
    • GlobusComputeEngine.assert_ha_compliant()
    • GlobusComputeEngine.containerized_launch_cmd()
    • GlobusComputeEngine.get_connected_managers()
    • GlobusComputeEngine.get_connected_managers_packages()
    • GlobusComputeEngine.get_total_managers()
    • GlobusComputeEngine.get_total_active_managers()
    • GlobusComputeEngine.get_outstanding_breakdown()
    • GlobusComputeEngine.get_total_tasks_outstanding()
    • GlobusComputeEngine.get_total_tasks_pending()
    • GlobusComputeEngine.get_total_live_workers()
    • GlobusComputeEngine.get_total_idle_workers()
    • GlobusComputeEngine.scaling_enabled
    • GlobusComputeEngine.get_status_report()
• Globus MPI Engine
  • GlobusMPIEngine
• ShellFunction
  • ShellFunction
    • ShellFunction.__call__()
  • ShellResult
• MPIFunction
  • MPIFunction
    • MPIFunction.__call__()