@gen.engine
def _Start(callback):
  client = db_client.DBClient.Instance()
  job = Job(client, 'merge_logs')

  if options.options.require_lock:
    got_lock = yield gen.Task(job.AcquireLock)
    if got_lock == False:
      logging.warning('Failed to acquire job lock: exiting.')
      callback()
      return

  try:
    yield gen.Task(RunOnce)
  finally:
    yield gen.Task(job.ReleaseLock)

  callback()
Return true if the adapter has access to the storage adapter context.
dataset/ETHPy150Open viewfinderco/viewfinder/backend/logs/get_server_logs.py/_Start--crossover with--dataset/ETHPy150Open gunthercox/ChatterBot/chatterbot/adapters/logic/base_match.py/BaseMatchAdapter.has_storage_context