def synch_db():
    """ function reads managed_process and updates context entries appropriately """
    logger = get_logger(PROCESS_SCHEDULER)
    managed_process_dao = ManagedProcessDao(logger)

    try:
        process_entries = managed_process_dao.get_all()
    except LookupError:
        logger.error('Synergy DB is not initialized. Aborting.')
        exit(1)

    for process_entry in process_entries:
        process_name = process_entry.process_name
        if process_name not in context.process_context:
            logger.warning('Process {0} has no reflection in the context. Skipping it.'.format(process_name))
            continue

        if not isinstance(context.process_context[process_name], ManagedProcessEntry):
            logger.error('Process entry {0} of non-managed type {1} found in managed_process table. Skipping it.'
                         .format(process_name, context.process_context[process_name].__class__.__name__))
            continue

        context.process_context[process_name] = process_entry
        logger.info('Context updated with process entry {0}.'.format(process_entry.key))
def synch_db ( ) : logger = get_logger ( PROCESS_SCHEDULER ) managed_process_dao = ManagedProcessDao ( logger ) try : process_entries = managed_process_dao . get_all ( ) except LookupError : logger . error ( 'Synergy DB is not initialized. Aborting.' ) exit ( 1 ) for process_entry in process_entries : process_name = process_entry . process_name if process_name not in context . process_context : logger . warning ( 'Process {0} has no reflection in the context. Skipping it.' . format ( process_name ) ) continue if not isinstance ( context . process_context [ process_name ] , ManagedProcessEntry ) : logger . error ( 'Process entry {0} of non-managed type {1} found in managed_process table. Skipping it.' . format ( process_name , context . process_context [ process_name ] . __class__ . __name__ ) ) continue context . process_context [ process_name ] = process_entry logger . info ( 'Context updated with process entry {0}.' . format ( process_entry . key ) )
function reads managed_process and updates context entries appropriately