in lib/core/sync_job_runner.rb [194:216]
def claim_job!
Utility::Logger.info("Claiming job (ID: #{@job_id}) for connector (ID: #{@connector_id}).")
if @connector_settings.running?
Utility::Logger.warn("Failed to claim job (ID: #{@job_id}) for connector (ID: #{@connector_id}), there are already jobs running.")
return false
end
begin
Core::ElasticConnectorActions.update_connector_sync_start(@connector_id)
@job.make_running!
Utility::Logger.info("Successfully claimed job (ID: #{@job_id}) for connector (ID: #{@connector_id}).")
true
rescue StandardError => e
Utility::ExceptionTracking.log_exception(e)
Utility::Logger.error("Failed to claim job (ID: #{@job_id}) for connector (ID: #{@connector_id}). Please check the logs for the cause of this error.")
false
end
end