def METHOD_NAME(self, rcfg):
    url     = rcfg['job_manager_endpoint']
    schemas = url.split(':')[0].split('+')
    if 'ssh' in schemas:
        schemas.remove('ssh')
    if 'gsissh' in schemas:
        schemas.remove('gsissh')
    if len(schemas) > 1:
        return
    if not schemas:
        return
    schema = schemas[0]
    if schema == 'fork':
        schema = 'local'
    return schema