manager package¶

Submodules¶

manager.job module¶

class manager.job.TxJob(data, quiet=False)[source]¶

Bases: manager.object.TxObject

db_fields = [u'job_id', u'user', u'identifier', u'convert_module', u'created_at', u'expires_at', u'started_at', u'ended_at', u'eta', u'resource_type', u'input_format', u'source', u'output_format', u'output', u'cdn_bucket', u'cdn_file', u'callback', u'links', u'status', u'success', u'message', u'log', u'warnings', u'errors']¶

manager.manager module¶

class manager.manager.TxManager(api_url=None, gogs_url=None, cdn_url=None, cdn_bucket=None, quiet=False, aws_access_key_id=None, aws_secret_access_key=None, job_table_name=None, module_table_name=None)[source]¶

Bases: object

JOB_TABLE_NAME = u'tx-job'¶

MODULE_TABLE_NAME = u'tx-module'¶

debug_print(message)[source]¶

delete_job(job)[source]¶

delete_module(module)[source]¶

static do_callback(url, payload)[source]¶

generate_dashboard()[source]¶

Generate page with metrics indicating configuration of tx-manager.

Parameters:	event (dict) – context – DynamicDBHandler – logger –

get_converter_module(job)[source]¶

get_job(job_id)[source]¶

get_module(name)[source]¶

get_user(user_token)[source]¶

insert_job(job)[source]¶

insert_module(module)[source]¶

list_endpoints()[source]¶

list_jobs(data, must_be_authenticated=True)[source]¶

static make_api_gateway_for_module(module)[source]¶

query_jobs(data=None)[source]¶

query_modules(data=None)[source]¶

register_module(data)[source]¶

setup_job(data)[source]¶

setup_resources()[source]¶

start_job(job_id)[source]¶

update_job(job)[source]¶

update_module(module)[source]¶

manager.module module¶

class manager.module.TxModule(data, quiet=False)[source]¶