Workers API¶
CADC Certs¶
Deleter¶
Processed Data Fetcher¶
Replication Healer¶
Replication healer.
heal_staged_file_replicas
¶
Python
heal_staged_file_replicas(target_storage_element, replica_paths, replica_ids, datasets, scopes)
Heal file replicas left as staged.
Replicator¶
Replication worker.
get_destination
¶
Get the destination file path or uri to push the file to.
main
¶
Main function.
Parameters:
Name | Type | Description | Default |
---|---|---|---|
replicate_from
|
str
|
storage element from where to replocicate data. |
required |
replicate_to
|
str
|
storage element where to replocicate data. |
required |
update_work_status
¶
Python
update_work_status(replica_id, transformation, status, storage_element, file_path, md5sum, dataset_name, dataset_scope, storage_element_captured_at)
Update the status of work.