src/main/java/org/embulk/input/marketo/delegate/MarketoBaseInputPluginDelegate.java in embulk-input-marketo-0.5.7.alpha.4 vs src/main/java/org/embulk/input/marketo/delegate/MarketoBaseInputPluginDelegate.java in embulk-input-marketo-0.5.7.alpha.5

@@ -12,10 +12,11 @@
 import org.embulk.input.marketo.rest.MarketoRestClient;
 import org.embulk.spi.Exec;
 import org.embulk.spi.Schema;
 import org.embulk.util.retryhelper.jetty92.DefaultJetty92ClientCreator;
 import org.embulk.util.retryhelper.jetty92.Jetty92RetryHelper;
+import org.joda.time.DateTime;
 
 import java.util.List;
 
 /**
  * Created by tai.khuu on 9/18/17.
@@ -48,10 +49,13 @@
         @ConfigDefault("[]")
         List<String> getExtractedFields();
 
         void setExtractedFields(List<String> extractedFields);
 
+        DateTime getJobStartTime();
+
+        void setJobStartTime(DateTime dateTime);
     }
 
     @Override
     public ConfigDiff buildConfigDiff(T task, Schema schema, int taskCount, List<TaskReport> taskReports)
     {
@@ -59,9 +63,10 @@
     }
 
     @Override
     public void validateInputTask(T task)
     {
+        task.setJobStartTime(DateTime.now());
     }
 
     @VisibleForTesting
     public MarketoRestClient createMarketoRestClient(PluginTask task)
     {