aces.clink.tasks¶
Module Contents¶
Functions¶
|
A prefect task that will emit a clink based event to inform other systems that data-processing has gone through a state change |
- aces.clink.tasks.task_create_emit_clink_event(secret_block: str, sbid: int, workdir: pathlib.Path, operation: str, state: str = 'completed') None[source]¶
A prefect task that will emit a clink based event to inform other systems that data-processing has gone through a state change
- Args:
secret_block (str): Name of registered Prefect Secret block corresponding to the desired clink url (which includes authentication) sbid (int): SBID being processed workdir (Path): The location of the work that has been carried out operation (str): Specifies the type of work that has been carried out. For example, holography of sefd state (str, optional): The state of the processing that should be advertised. Defaults to ‘completed’.