Class: AwDatapipe::PipelineSerializer

Inherits:
Object
  • Object
show all
Defined in:
lib/aw_datapipe/pipeline_serializer.rb

Overview

Converts a pipeline into a format that can be submitted to the AWS client SDK.

Instance Method Summary collapse

Instance Method Details

#marshal(pipeline) ⇒ Object 



4
5
6
7
8
9
10
11
 
# File 'lib/aw_datapipe/pipeline_serializer.rb', line 4

def marshal(pipeline)
  {
    pipeline_id: pipeline.id,
    pipeline_objects: marshal_pipeline_objects(pipeline),
    parameter_objects: marshal_parameter_objects(pipeline.parameter_metadata),
    parameter_values: marshal_parameter_values(pipeline.parameter_values)
  }
end

#unmarshal(aws_definition) ⇒ Object 



13
14
15
16
17
18
19
20
 
# File 'lib/aw_datapipe/pipeline_serializer.rb', line 13

def unmarshal(aws_definition)
  # pipeline.aws_definition = aws_definition # for troubleshooting
  objects = unmarshal_pipeline_objects(aws_definition.pipeline_objects)
  parameter_metadata = unmarshal_parameter_objects(aws_definition.parameter_objects)
  parameter_values = unmarshal_parameter_values(aws_definition.parameter_values)

  Pipeline.new(objects, parameter_metadata, parameter_values)
end