Sha256: 4d1863aa284947c86cda7d5d95c0df20507be756add2bf97f5b1e3668b6e62a3
Contents?: true
Size: 371 Bytes
Versions: 51
Compression:
Stored size: 371 Bytes
Contents
module EasyML
class SyncDatasourceJob < ApplicationJob
queue_as :easy_ml
def perform(id)
datasource = EasyML::Datasource.find(id)
create_event(datasource, "started")
begin
datasource.refresh
rescue StandardError => e
datasource.update!(is_syncing: false)
handle_error(datasource, e)
end
end
end
end
Version data entries
51 entries across 51 versions & 1 rubygems