<s> import luigi <EOL> import target <EOL> from luigi_gcloud . dataflow import DataFlowJavaTask <EOL> from storage_tasks import CopyLocalToStorage <EOL> class CopyViaDataFlowToStorage ( DataFlowJavaTask ) : <EOL> day = luigi . DateParameter ( ) <EOL> def output ( self ) : <EOL> return target . storage_mail ( self . day , '<STR_LIT>' ) . gcs <EOL> def requires ( self ) : <EOL> return CopyLocalToStorage ( self . day ) <EOL> def dataflow ( self ) : <EOL> return "<STR_LIT>" <EOL> def configuration ( self ) : <EOL> return { <EOL> "<STR_LIT>" : "<STR_LIT>" , <EOL> "<STR_LIT>" : "<STR_LIT>" , <EOL> "<STR_LIT>" : "<STR_LIT:3>" <EOL> } <EOL> def variables ( self ) : <EOL> return { <EOL> '<STR_LIT>' : target . storage_mail_path ( self . day ) . path , <EOL> '<STR_LIT>' : target . storage_mail ( self . day , '<STR_LIT>' ) . path <EOL> } </s>
