datamanwithvan.replication package

Submodules

datamanwithvan.replication.datamanwithvanmover module

datamanwithvan.replication.replicationjob module

class datamanwithvan.replication.replicationjob.ReplicationJob(replication_job_id, configuration, verbosity, mainprogram_job_channel)[source]

Bases: object

_summary_

Returns:

_description_

Return type:

_type_

StatusCodesObj = <datamanwithvan.utils.statuscodes.StatusCodes object>
assign_replication_rules(replication_rules)[source]

For every replication rule in the job, make a separate thread to handle it - dummy change 2

configuration = <datamanwithvan.config.config.datamanwithvanConfig object>
async consume(communication, whoami)[source]

_summary_

Parameters:

  • communication (BidirectionalQueue) – _description_

  • whoami (_type_) – _description_

content = None
job_metadata = {'comments': '', 'job_finished': '', 'job_friendly_name': '', 'job_id': 0, 'job_started': 1723270525.735937, 'job_status': '', 'job_tasks': []}
job_task_channel = <datamanwithvan.utils.bidirectional_queue.BidirectionalQueue object>
main_to_job_channel = None
mainprogram_job_channel = <datamanwithvan.utils.bidirectional_queue.BidirectionalQueue object>
async produce(communication, sender, message)[source]

_summary_

Parameters:

  • communication (BidirectionalQueue) – _description_

  • sender (_type_) – _description_

  • message (_type_) – _description_

query_engine = None
replication_job_id = None
run_job(replication_job_id)[source]

_summary_

Parameters:

replication_job_id (_type_) – _description_

Returns:

_description_

Return type:

_type_

start_replication_tasks()[source]

_summary_

Returns:

_description_

Return type:

_type_

tasks = []
verbosity = True

datamanwithvan.replication.replicationtask module

class datamanwithvan.replication.replicationtask.ReplicationTask(replication_rule, config, verbosity=True)[source]

Bases: object

_summary_

Returns:

_description_

Return type:

_type_

StatusCodesObj = <datamanwithvan.utils.statuscodes.StatusCodes object>
config = ''
replication_item = {'comments': '', 'finished': '', 'origin_path': '', 'size_bytes': 0, 'started': '', 'status': None, 'targeet_path': ''}
run_task()[source]

_summary_

Returns:

_description_

Return type:

_type_

task_metadata = {'comments': '', 'finished': '', 'items': [], 'origin_agent': '', 'partition_filter': '', 'repl_rule_id': None, 'started': '', 'status': None, 'target_agent': '', 'transfer_mode': ''}
verbosity = True

Module contents