Sha256: 8a1cef37f614b84b3e623768432b37e519604ddaa6d9117c090ad9abcf760798
Contents?: true
Size: 915 Bytes
Versions: 8
Compression:
Stored size: 915 Bytes
Contents
module CanvasSync
module Jobs
# Starts a Canvas report and enqueues a ReportChecker
class ReportStarter < CanvasSync::Job
# @param job_chain [Hash]
# @param report_name [Hash] e.g., 'provisioning_csv'
# @param report_params [Hash] The Canvas report parameters
# @param processor [String] a stringified report processor class name
# @param options [Hash] hash of options that will be passed to the job processor
# @return [nil]
def perform(job_chain, report_name, report_params, processor, options)
report = CanvasSync.get_canvas_sync_client(job_chain[:global_options]).start_report('self', report_name, report_params)
CanvasSync::Jobs::ReportChecker.set(wait: report_checker_wait_time).perform_later(
job_chain,
report_name,
report['id'],
processor,
options
)
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems