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 AMQP connection.


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 to MQ channel.


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.


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.