Fix handling of scheduled jobs.

Author: samuel-williams-shopify

lib/active_job/queue_adapters/async_job_adapter.rb

@@ -20,14 +20,19 @@ def initialize(dispatcher = ::Async::Job::Adapter::ActiveJob::Railtie.dispatcher
 			end
 
 			# Enqueue a job for processing.
+			# @parameter job [ActiveJob::Base] The job to enqueue.
 			def enqueue(job)
 				Sync do
 					@dispatcher.call(job)
 				end
 			end
 
 			# Enqueue a job for processing at a specific time.
+			# @parameter job [ActiveJob::Base] The job to enqueue.
+			# @parameter timestamp [Time] The time at which to enqueue the job.
 			def enqueue_at(job, timestamp)
+				job.scheduled_at = timestamp
+				
 				Sync do
 					@dispatcher.call(job)
 				end

test/active_job/queue_adapters/async_job_adapter.rb

@@ -69,7 +69,7 @@
 	with "#enqueue_at" do
 		let(:adapter) {subject.new(dispatcher)}
 		let(:job) {TestJob.new}
-		let(:timestamp) {Time.now + 60}
+		let(:timestamp) {Time.now}
 
 		before do
 			dispatcher.queues["default"] = queue
@@ -84,6 +84,7 @@
 					"job_class" => be == "TestJob",
 					"queue_name" => be == "default",
 					"arguments" => be == [],
+					"scheduled_at" => be == timestamp.iso8601(9),
 				)
 			end
 		end