jobs/transforms/parse_date_job.rb in remi-0.2.13 vs jobs/transforms/parse_date_job.rb in remi-0.2.14
- old
+ new
@@ -5,17 +5,21 @@
define_param :format, '%Y-%m-%d'
define_param :if_blank, nil
define_source :source_data, Remi::DataSource::DataFrame,
fields: {
- :date_string => {}
+ :date_string => { type: :date, format: params[:format] },
+ :stubbed_date => { type: :date, format: params[:format] }
}
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(:date_string) .target(:parsed_date)
+ .transform(Remi::Transform[:parse_date].(format: params[:format], if_blank: params[:if_blank]))
+
+ map source(:stubbed_date) .target(:parsed_stubbed_date)
.transform(Remi::Transform[:parse_date].(format: params[:format], if_blank: params[:if_blank]))
end
end
end