rucio_utils

Utility functions for interacting with the Rucio web API.

class merge_utils.rucio_utils.RucioWrapper

Class for sending asynchronous requests to the Rucio web API.

Initialize the RucioWrapper.

async connect() → None

Connect to the Rucio web API

async disconnect() → None

No need to explicitly disconnect from Rucio?

async get_replicas(files: list) → list

Asynchronously retrieve replicas for a specific batch of files.

Parameters:

files – list of files to retrieve paths for

Returns:

list of file path dictionaries

async get_rse(name: str) → dict

Asynchronously retrieve information for a specific RSEfrom Rucio.

Parameters:

name – name of the RSE to retrieve

Returns:

dictionary of RSE attributes

async get_rses(detailed: bool = True) → AsyncGenerator[dict, None]

Asynchronously retrieve information for all RSEs from Rucio.

Parameters:

detailed – whether to include detailed RSE information

Returns:

dictionary of RSE attributes for each RSE