lib/remi/project/jobs/transforms/date_diff_job.rb in remi-0.2.6 vs lib/remi/project/jobs/transforms/date_diff_job.rb in remi-0.2.7

@@ -2,10 +2,14 @@
 
 class DateDiffJob
   include AllJobsShared
 
   define_param :measure, :days
-  define_source :source_data, Remi::DataSource::DataFrame
+  define_source :source_data, Remi::DataSource::DataFrame,
+    fields: {
+      :date1 => { type: :date, format: '%Y-%m-%d' },
+      :date2 => { type: :date, format: '%Y-%m-%d' }
+    }
   define_target :target_data, Remi::DataTarget::DataFrame
 
   define_transform :main, sources: :source_data, targets: :target_data do
     Remi::SourceToTargetMap.apply(source_data.df, target_data.df) do
       map source(:date1, :date2) .target(:difference)