lib/remi/project/jobs/copy_source_job.rb in remi-0.2.6 vs lib/remi/project/jobs/copy_source_job.rb in remi-0.2.7
- old
+ new
@@ -2,10 +2,14 @@
class CopySourceJob
include AllJobsShared
using Remi::Refinements::Daru
- define_source :source_data, Remi::DataSource::DataFrame
+ define_source :source_data, Remi::DataSource::DataFrame,
+ fields: {
+ :some_field => {},
+ :some_date => { type: :date, format: '%Y-%m-%d' }
+ }
define_source :target_data, Remi::DataSource::DataFrame
define_transform :main, sources: :source_data, targets: :target_data do
target_data.df = source_data.df.dup
end