2. API
2.1. REANA AMQP Publisher
REANA-Commons module to manage AMQP connections on REANA.
-
class
reana_commons.publisher.Publisher[source]
Progress publisher to MQ.
-
close()[source]
Close AMQP connection.
-
connect()[source]
Connect to MQ channel.
-
publish_workflow_status(workflow_uuid, status, logs='', message=None)[source]
Publish msg, reconnecting if necessary.
2.2. REANA AMQP Consumer
REANA-Commons module to manage AMQP consuming on REANA.
-
class
reana_commons.consumer.Consumer(queue)[source]
Base MQ Consumer.
-
connect()[source]
Connect to MQ channel.
-
consume()[source]
Start consuming incoming messages.
-
on_message(channel, method_frame, header_frame, body)[source]
On new message event handler.
2.3. REANA utilities
REANA-Commons utils.
-
reana_commons.utils.calculate_file_access_time(workflow_workspace)[source]
Calculate access times of files in workspace.
-
reana_commons.utils.calculate_hash_of_dir(directory, file_list=None)[source]
Calculate hash of directory.
-
reana_commons.utils.calculate_job_input_hash(job_spec, workflow_json)[source]
Calculate md5 hash of job specification and workflow json.
-
reana_commons.utils.click_table_printer(headers, _filter, data)[source]
Generate space separated output for click commands.
