def __init__(self, data_store: DataStore, *, max_concurrent_jobs: int=100, identity: Optional[str]=None, logger: Optional[Logger]=None, run_sync_functions_in_event_loop: bool=True):
    super().__init__()
    self.data_store = data_store
    self.max_concurrent_jobs = max_concurrent_jobs
    self.identity = (identity or f'{platform.node()}-{os.getpid()}-{threading.get_ident()}')
    self.logger = (logger or getLogger(__name__))
    self.run_sync_functions_in_event_loop = run_sync_functions_in_event_loop
    self._acquired_jobs: Set[Job] = set()
    self._exit_stack = AsyncExitStack()
    if (self.max_concurrent_jobs < 1):
        raise ValueError('max_concurrent_jobs must be at least 1')
def __init__(self, data_store: DataStore, *, max_concurrent_jobs: int=100, identity: Optional[str]=None, logger: Optional[Logger]=None, run_sync_functions_in_event_loop: bool=True):
    super().__init__()
    self.data_store = data_store
    self.max_concurrent_jobs = max_concurrent_jobs
    self.identity = (identity or f'{platform.node()}-{os.getpid()}-{threading.get_ident()}')
    self.logger = (logger or getLogger(__name__))
    self.run_sync_functions_in_event_loop = run_sync_functions_in_event_loop
    self._acquired_jobs: Set[Job] = set()
    self._exit_stack = AsyncExitStack()
    if (self.max_concurrent_jobs < 1):
        raise ValueError('max_concurrent_jobs must be at least 1')