lib/dirty_pipeline/base.rb in dirty_pipeline-0.6.3 vs lib/dirty_pipeline/base.rb in dirty_pipeline-0.6.4

@@ -83,10 +83,10 @@
     def retry
       return self if (enqueued_event = railway.queue.processing_event).nil?
       execute(load_event(enqueued_event), attempt_retry: true)
     end
 
-    def schedule(operation, delay = nil)
+    def schedule(operation = "call", delay = nil)
       job_args = {
         "transaction_id" => @uuid,
         "enqueued_pipeline" => self.class.to_s,
         "find_subject_args" => find_subject_args,
         "operation" => operation,