Globus

Classes¶

GlobusTransferTool(
    external_host,
    logger=logging.log,
    group_bulk=200,
    group_policy="single",
)

Globus implementation of Transfertool abstract base class

Initializes the transfertool

PARAMETER	DESCRIPTION
`external_host`	The external host where the transfertool API is running

submit_one(files, timeout=None)

Submit transfers to globus API

PARAMETER	DESCRIPTION
`files`	List of dictionaries describing the file transfers.
`job_params`	Dictionary containing key/value pairs, for all transfers.
`timeout`	Timeout in seconds. DEFAULT: `None`

RETURNS	DESCRIPTION
	Globus transfer identifier.

submit(transfers, job_params, timeout=None)

Submit a bulk transfer to globus API

PARAMETER	DESCRIPTION
`transfers`	List of dictionaries describing the file transfers.
`job_params`	Not used by Globus Transfsertool
`timeout`	Timeout in seconds. DEFAULT: `None`

RETURNS	DESCRIPTION
	Globus transfer identifier.

bulk_query(requests_by_eid, timeout=None)

Query the status of a bulk of transfers in globus API

PARAMETER	DESCRIPTION
`requests_by_eid`	dictionary {external_id1: {request_id1: request1, ...}, ...}

RETURNS	DESCRIPTION
	Transfer status information as a dictionary.

bulk_group_transfers(
    transfer_paths, policy="single", group_bulk=200
)

Group transfers in bulk based on certain criteria

PARAMETER	DESCRIPTION
`transfer_paths`	List of (potentially multihop) transfer paths to group. Each path is a list of single-hop transfers.
`policy`	Policy to use to group. DEFAULT: `'single'`
`group_bulk`	Bulk sizes. DEFAULT: `200`

RETURNS	DESCRIPTION
	List of transfer groups