Requestclient

Classes¶

RequestClient ¶

RequestClient(
    rucio_host=None,
    auth_host=None,
    account=None,
    ca_cert=None,
    auth_type=None,
    creds=None,
    timeout=600,
    user_agent="rucio-clients",
    vo=None,
    logger=LOG,
)

Functions¶

list_requests ¶

list_requests(src_rse, dst_rse, request_states)

Return latest request details

RETURNS	DESCRIPTION
`request information`

list_requests_history ¶

list_requests_history(
    src_rse, dst_rse, request_states, offset=0, limit=100
)

Return historical request details

RETURNS	DESCRIPTION
`request information`

list_request_by_did ¶

list_request_by_did(name, rse, scope=None)

Return latest request details for a DID

PARAMETER	DESCRIPTION
`name`	DID TYPE: `str`
`rse`	Destination RSE name TYPE: `str`
`scope`	rucio scope, defaults to None TYPE: `Optional[str]` DEFAULT: `None`

RAISES	DESCRIPTION
`exc_cls: from BaseClient._get_exception`

RETURNS	DESCRIPTION
`request information`

list_request_history_by_did ¶

list_request_history_by_did(name, rse, scope=None)

Return latest request details for a DID

PARAMETER	DESCRIPTION
`name`	DID TYPE: `str`
`rse`	Destination RSE name TYPE: `str`
`scope`	rucio scope, defaults to None TYPE: `Optional[str]` DEFAULT: `None`

RAISES	DESCRIPTION
`exc_cls: from BaseClient._get_exception`

RETURNS	DESCRIPTION
`request information`

list_transfer_limits ¶

list_transfer_limits()

Returns all the transfer limits

:returns: transfer limits

set_transfer_limit ¶

set_transfer_limit(
    rse_expression,
    activity=None,
    direction=TransferLimitDirection.DESTINATION,
    max_transfers=None,
    volume=None,
    deadline=None,
    strategy=None,
    transfers=None,
    waitings=None,
)

Set the transfer limit for a given RSE

:param rse_expression: RSE expression string. :param activity: The activity. :param direction: The direction in which this limit applies (source/destination) :param max_transfers: Maximum transfers. :param volume: Maximum transfer volume in bytes. :param deadline: Maximum waiting time in hours until a datasets gets released. :param strategy: defines how to handle datasets: fifo (each file released separately) or grouped_fifo (wait for the entire dataset to fit) :param transfers: Current number of active transfers :param waitings: Current number of waiting transfers

:returns: True if the transfer limit was deleted

delete_transfer_limit ¶

delete_transfer_limit(
    rse_expression,
    activity=None,
    direction=TransferLimitDirection.DESTINATION,
)

Delete the transfer limit for a given RSE

:param rse_expression: RSE expression string. :param activity: The activity. :param direction: The direction in which this limit applies (source/destination)

:returns: True if the transfer limit was deleted