Module Expr Str ImportFrom alias Import alias Import alias Import alias Import alias ImportFrom alias FunctionDef arguments args defaults body Expr Str Return IfExp CompareIn Str NameLoad Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad Str NameLoad Str NameLoad Str NameLoad NameLoad NameLoad NameLoad body Expr Str Assign NameStore Dict Str Str Str Str NameLoad NameLoad Str Dict Assign NameStore BoolOpOr NameLoad Dict Assign NameStore BoolOpOr NameLoad Dict Assign NameStore BoolOpOr NameLoad Dict Assign TupleStore NameStore NameStore Call NameLoad NameLoad Call NameLoad NameLoad NameLoad Call NameLoad NameLoad NameLoad Call NameLoad NameLoad NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If NameLoad body Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad Return NameLoad If SubscriptLoad NameLoad Index Str body Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad Assign SubscriptStore NameLoad Index Str NameLoad Return NameLoad Assign NameStore Call SubscriptLoad NameLoad Index Str NameLoad NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If CompareIn Str NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad SubscriptLoad NameLoad Index Str Return NameLoad Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore Call SubscriptLoad NameLoad Index Str NameLoad Call NameLoad NameLoad NameLoad keyword Call NameLoad NameLoad NameLoad keyword Call NameLoad NameLoad NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If CompareIn Str NameLoad body If Call NameLoad NameLoad body Assign NameStore Call SubscriptLoad NameLoad Index Str NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If CompareIn Str NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad SubscriptLoad NameLoad Index Str Return NameLoad Assign NameStore Call SubscriptLoad NameLoad Index Str NameLoad NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If CompareIn Str NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad SubscriptLoad NameLoad Index Str Return NameLoad Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore Call SubscriptLoad NameLoad Index Str NameLoad Call NameLoad NameLoad NameLoad keyword Call NameLoad NameLoad NameLoad keyword Call NameLoad NameLoad NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If CompareIn Str NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad SubscriptLoad NameLoad Index Str Return NameLoad Assign NameStore Call SubscriptLoad NameLoad Index Str NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If CompareIn Str NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad SubscriptLoad NameLoad Index Str Return NameLoad Assign NameStore Call SubscriptLoad NameLoad Index Str NameLoad keyword Str keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If CompareIn Str NameLoad body Assign NameStore Dict orelse Assign NameStore Call NameLoad SubscriptLoad NameLoad Index Str If UnaryOpNot NameLoad body Assign SubscriptStore SubscriptLoad NameLoad Index Str Index Str Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad orelse Assign SubscriptStore SubscriptLoad NameLoad Index Str Index Str Call NameLoad NameLoad NameLoad Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str For NameStore SubscriptLoad NameLoad Index Str body For NameStore SubscriptLoad NameLoad Index Str body If CompareIn Str NameLoad body Return NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call SubscriptLoad NameLoad Index Str NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If CompareIn Str NameLoad body Return TupleLoad NameLoad Dict Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore Call SubscriptLoad NameLoad Index Str NameLoad keyword Str keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If CompareIn Str NameLoad body Return TupleLoad NameLoad Dict Assign NameStore Call NameLoad SubscriptLoad NameLoad Index Str Assign NameStore Call AttributeLoad NameLoad attr Str Assign NameStore Call AttributeLoad NameLoad attr Str Assign NameStore Call AttributeLoad NameLoad attr Str Assign NameStore BoolOpAnd Call NameLoad Call NameLoad NameLoad Call NameLoad NameLoad Call NameLoad NameLoad NameLoad Call NameLoad NameLoad NameLoad Return TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad For NameStore NameLoad body If CompareEq SubscriptLoad NameLoad Index Str Str body For NameStore SubscriptLoad NameLoad Index Str body If CompareEq SubscriptLoad NameLoad Index Str Str body Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad NameLoad attr Str Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str If Call NameLoad NameLoad NameLoad body If CompareIs NameLoad NameLoad body Assign NameStore ListLoad If CompareNotEq Call NameLoad NameLoad Call NameLoad NameLoad body Return NameLoad Expr Call AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad NameLoad attr keyword NameLoad For TupleStore NameStore NameStore Call NameLoad NameLoad NameLoad body If UnaryOpNot Call NameLoad NameLoad NameLoad body Return NameLoad Return NameLoad orelse If Call NameLoad NameLoad NameLoad body If CompareIs NameLoad NameLoad body Assign NameStore Dict Assign NameStore Call NameLoad NameLoad Assign NameStore Call NameLoad NameLoad If CompareNotEq Call NameLoad NameLoad Call NameLoad NameLoad body Return NameLoad For NameStore NameLoad body If UnaryOpNot Call NameLoad SubscriptLoad NameLoad Index NameLoad SubscriptLoad NameLoad Index NameLoad body Return NameLoad Return NameLoad orelse Return CompareEq NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str If Call NameLoad NameLoad NameLoad body If CompareIn Str NameLoad body Return SubscriptLoad NameLoad Index Str If CompareIn Str NameLoad body Return SubscriptLoad NameLoad Index Str Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad Call AttributeLoad NameLoad attr NameLoad keyword Num attr Num Call AttributeLoad Call AttributeLoad NameLoad attr NameLoad keyword Num attr Num Return Call AttributeLoad Str attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str FunctionDef arguments args NameParam defaults body If Call NameLoad NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr keyword NameLoad For NameStore NameLoad body Expr Call NameLoad NameLoad orelse If Call NameLoad NameLoad NameLoad body Assign NameStore Call NameLoad NameLoad For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body Expr Call NameLoad NameLoad Expr Call NameLoad NameLoad decorator_list Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr Call SubscriptLoad NameLoad Index Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call NameLoad Call NameLoad NameLoad For NameStore NameLoad body Assign SubscriptStore NameLoad Index Str Call NameLoad SubscriptLoad NameLoad Index Str Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr Call SubscriptLoad NameLoad Index Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call NameLoad Call NameLoad NameLoad For NameStore NameLoad body Assign SubscriptStore NameLoad Index Str Call NameLoad SubscriptLoad NameLoad Index Str Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr Call SubscriptLoad NameLoad Index Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call NameLoad NameLoad Return Call NameLoad NameLoad keyword Str decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore ListLoad For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body Assign NameStore Dict Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults Str body Expr Str Assign NameStore ListLoad For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body If Call NameLoad NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Dict NameLoad Str NameLoad SubscriptLoad NameLoad Index Str orelse Expr Call AttributeLoad NameLoad attr Dict NameLoad Str NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad body Expr Str Assign NameStore Dict Str Str Str Str NameLoad NameLoad Str Dict Assign NameStore Call SubscriptLoad NameLoad Index Str NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad If CompareNotIn Str NameLoad body Assign NameStore SubscriptLoad NameLoad Index Str If SubscriptLoad NameLoad Index Str body Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad Assign SubscriptStore NameLoad Index Str NameLoad Return NameLoad orelse Expr Call SubscriptLoad NameLoad Index Str NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad Assign SubscriptStore SubscriptLoad NameLoad Index Str Index Str Dict Str NameLoad Assign SubscriptStore SubscriptLoad NameLoad Index Str Index Str NameLoad orelse Assign SubscriptStore NameLoad Index Str Call AttributeLoad Str attr NameLoad Return NameLoad decorator_list
N/A N/A 
Manage Data Pipelines

.. versionadded:: 2016.3.0

Be aware that this interacts with Amazon's services, and so may incur charges.

This module uses ``boto3``, which can be installed via package, or pip.

This module accepts explicit AWS credentials but can also utilize
IAM roles assigned to the instance through Instance Profiles. Dynamic
credentials are then automatically obtained from AWS API and no further
configuration is necessary. More information available `here
<http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/iam-roles-for-amazon-ec2.html>`_.

If IAM roles are not used you need to specify them either in a pillar file or
in the minion's config file:

.. code-block:: yaml

    datapipeline.keyid: GKTADJGHEIQSXMKKRBJ08H
    datapipeline.key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs

It's also possible to specify ``key``, ``keyid`` and ``region`` via a profile,
either passed in as a dict, or as a string to pull from pillars or minion
config:

.. code-block:: yaml

  myprofile:
    keyid: GKTADJGHEIQSXMKKRBJ08H
    key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs
    region: us-east-1

.. code-block:: yaml

  Ensure daily data pipeline exists:
    boto_datapipeline.present:
      - name: my-datapipeline
      - pipeline_objects:
          DefaultSchedule:
            name: Every 1 day
            fields:
              period: 1 Day
              type: Schedule
              startAt: FIRST_ACTIVATION_DATE_TIME
      - parameter_values:
          myDDBTableName: my-dynamo-table
 __future__ absolute_import N/A copy N/A datetime N/A difflib N/A json salt.ext.six.moves zip __virtual__ N/A N/A N/A N/A N/A 
    Only load if boto is available.
     N/A N/A N/A boto_datapipeline.create_pipeline __salt__ boto_datapipeline False N/A present N/A N/A name pipeline_objects pipeline_objects_from_pillars parameter_objects parameter_objects_from_pillars parameter_values parameter_values_from_pillars region key keyid profile N/A None boto_datapipeline_pipeline_objects None boto_datapipeline_parameter_objects None boto_datapipeline_parameter_values None None None None N/A N/A 
    Ensure the data pipeline exists with matching definition.

    name
        Name of the service to ensure a data pipeline exists for.

    pipeline_objects
        Pipeline objects to use. Will override objects read from pillars.

    pipeline_objects_from_pillars
        The pillar key to use for lookup.

    parameter_objects
        Parameter objects to use. Will override objects read from pillars.

    parameter_objects_from_pillars
        The pillar key to use for lookup.

    parameter_values
        Parameter values to use. Will override values read from pillars.

    parameter_values_from_pillars
        The pillar key to use for lookup.

    region
        Region to connect to.

    key
        Secret key to be used.

    keyid
        Access key to be used.

    profile
        A dict with region, key and keyid, or a pillar key (string)
        that contains a dict with region, key and keyid.
     N/A ret N/A name result comment changes name True N/A N/A pipeline_objects N/A pipeline_objects N/A N/A parameter_objects N/A parameter_objects N/A N/A parameter_values N/A parameter_values N/A N/A N/A present old_pipeline_definition N/A _pipeline_present_with_definition name N/A _pipeline_objects pipeline_objects_from_pillars pipeline_objects N/A _parameter_objects parameter_objects_from_pillars parameter_objects N/A _parameter_values parameter_values_from_pillars parameter_values region region key key keyid keyid profile profile N/A present N/A N/A N/A ret N/A comment N/A N/A AWS data pipeline {0} present format name N/A ret N/A N/A __opts__ N/A test N/A N/A N/A ret N/A comment N/A N/A Data pipeline {0} is set to be created or updated format name N/A N/A ret N/A result None N/A ret N/A result_create_pipeline N/A N/A __salt__ N/A boto_datapipeline.create_pipeline name name region region key key keyid keyid profile profile N/A N/A error result_create_pipeline N/A N/A N/A ret N/A result False N/A N/A ret N/A comment N/A N/A Failed to create data pipeline {0}: {1} format name N/A result_create_pipeline N/A error N/A ret N/A pipeline_id N/A result_create_pipeline N/A result N/A result_pipeline_definition N/A N/A __salt__ N/A boto_datapipeline.put_pipeline_definition pipeline_id N/A _pipeline_objects pipeline_objects_from_pillars pipeline_objects parameter_objects N/A _parameter_objects parameter_objects_from_pillars parameter_objects parameter_values N/A _parameter_values parameter_values_from_pillars parameter_values region region key key keyid keyid profile profile N/A N/A error result_pipeline_definition N/A N/A N/A _immutable_fields_error result_pipeline_definition N/A N/A result_delete_pipeline N/A N/A __salt__ N/A boto_datapipeline.delete_pipeline pipeline_id region region key key keyid keyid profile profile N/A N/A error result_delete_pipeline N/A N/A N/A ret N/A result False N/A N/A ret N/A comment N/A N/A Failed to delete data pipeline {0}: {1} format pipeline_id N/A result_delete_pipeline N/A error N/A ret N/A result_create_pipeline N/A N/A __salt__ N/A boto_datapipeline.create_pipeline name name region region key key keyid keyid profile profile N/A N/A error result_create_pipeline N/A N/A N/A ret N/A result False N/A N/A ret N/A comment N/A N/A Failed to create data pipeline {0}: {1} format name N/A result_create_pipeline N/A error N/A ret N/A pipeline_id N/A result_create_pipeline N/A result N/A result_pipeline_definition N/A N/A __salt__ N/A boto_datapipeline.put_pipeline_definition pipeline_id N/A _pipeline_objects pipeline_objects_from_pillars pipeline_objects parameter_objects N/A _parameter_objects parameter_objects_from_pillars parameter_objects parameter_values N/A _parameter_values parameter_values_from_pillars parameter_values region region key key keyid keyid profile profile N/A N/A error result_pipeline_definition N/A N/A N/A ret N/A result False N/A N/A ret N/A comment N/A N/A Failed to create data pipeline {0}: {1} format name N/A result_pipeline_definition N/A error N/A ret N/A result_activate_pipeline N/A N/A __salt__ N/A boto_datapipeline.activate_pipeline pipeline_id region region key key keyid keyid profile profile N/A N/A error result_activate_pipeline N/A N/A N/A ret N/A result False N/A N/A ret N/A comment N/A N/A Failed to create data pipeline {0}: {1} format name N/A result_pipeline_definition N/A error N/A ret N/A pipeline_definition_result N/A N/A __salt__ N/A boto_datapipeline.get_pipeline_definition pipeline_id version active region region key key keyid keyid profile profile N/A N/A error pipeline_definition_result N/A N/A new_pipeline_definition N/A N/A N/A new_pipeline_definition N/A _standardize N/A pipeline_definition_result N/A result N/A N/A old_pipeline_definition N/A N/A N/A N/A ret N/A changes N/A new Pipeline created. N/A N/A ret N/A comment N/A N/A Data pipeline {0} created format name N/A N/A N/A N/A ret N/A changes N/A diff N/A _diff old_pipeline_definition new_pipeline_definition N/A N/A ret N/A comment N/A N/A Data pipeline {0} updated format name N/A ret N/A _immutable_fields_error N/A N/A result_pipeline_definition N/A N/A N/A Return true if update pipeline failed due to immutable fields

    Some fields cannot be changed after a pipeline has been activated.

    http://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-manage-pipeline-modify-console.html#dp-edit-pipeline-limits
     N/A e N/A result_pipeline_definition N/A error N/A N/A e2 N/A e N/A errors N/A N/A N/A can not be changed e2 N/A N/A True N/A False N/A _pipeline_present_with_definition N/A N/A name expected_pipeline_objects expected_parameter_objects expected_parameter_values region key keyid profile N/A N/A N/A 
    Return true if the pipeline exists and the definition matches.

    name
        The name of the pipeline.

    expected_pipeline_objects
        Pipeline objects that must match the definition.

    expected_parameter_objects
        Parameter objects that must match the definition.

    expected_parameter_values
        Parameter values that must match the definition.

    region
        Region to connect to.

    key
        Secret key to be used.

    keyid
        Access key to be used.

    profile
        A dict with region, key and keyid, or a pillar key (string)
        that contains a dict with region, key and keyid.
     N/A result_pipeline_id N/A N/A __salt__ N/A boto_datapipeline.pipeline_id_from_name name region region key key keyid keyid profile profile N/A N/A error result_pipeline_id N/A N/A N/A False N/A N/A pipeline_id N/A result_pipeline_id N/A result N/A pipeline_definition_result N/A N/A __salt__ N/A boto_datapipeline.get_pipeline_definition pipeline_id version active region region key key keyid keyid profile profile N/A N/A error pipeline_definition_result N/A N/A N/A False N/A N/A pipeline_definition N/A _standardize N/A pipeline_definition_result N/A result N/A pipeline_objects N/A N/A pipeline_definition get pipelineObjects N/A parameter_objects N/A N/A pipeline_definition get parameterObjects N/A paramater_values N/A N/A pipeline_definition get parameterValues N/A present N/A N/A _recursive_compare N/A _cleaned pipeline_objects N/A _cleaned expected_pipeline_objects N/A _recursive_compare parameter_objects expected_parameter_objects N/A _recursive_compare paramater_values expected_parameter_values N/A N/A present pipeline_definition N/A _cleaned N/A N/A _pipeline_objects N/A N/A N/A Return standardized pipeline objects to be used for comparing

    Remove year, month, and day components of the startDateTime so that data
    pipelines with the same time of day but different days are considered
    equal.
     N/A pipeline_objects N/A N/A copy deepcopy _pipeline_objects N/A pipeline_object pipeline_objects N/A N/A N/A N/A pipeline_object N/A id DefaultSchedule N/A N/A field_object N/A pipeline_object N/A fields N/A N/A N/A N/A field_object N/A key startDateTime N/A N/A start_date_time_string N/A field_object N/A stringValue N/A start_date_time N/A N/A N/A datetime datetime strptime start_date_time_string %Y-%m-%dT%H:%M:%S N/A N/A field_object N/A stringValue N/A N/A start_date_time strftime %H:%M:%S N/A pipeline_objects N/A _recursive_compare N/A N/A v1 v2 N/A N/A N/A 
    Return v1 == v2. Compares list, dict, recursively.
     N/A N/A isinstance v1 list N/A N/A N/A v2 None N/A N/A v2 N/A N/A N/A N/A len v1 N/A len v2 N/A N/A False N/A N/A N/A v1 sort key _id_or_key N/A N/A N/A v2 sort key _id_or_key N/A N/A x y N/A zip v1 v2 N/A N/A N/A N/A _recursive_compare x y N/A N/A False N/A True N/A N/A N/A isinstance v1 dict N/A N/A N/A v2 None N/A N/A v2 N/A N/A v1 N/A dict v1 N/A v2 N/A dict v2 N/A N/A N/A sorted v1 N/A sorted v2 N/A N/A False N/A k v1 N/A N/A N/A N/A _recursive_compare N/A v1 N/A k N/A v2 N/A k N/A N/A False N/A True N/A N/A N/A v1 v2 N/A _id_or_key N/A N/A list_item N/A N/A N/A 
    Return the value at key 'id' or 'key'.
     N/A N/A isinstance list_item dict N/A N/A N/A id list_item N/A N/A N/A list_item N/A id N/A N/A key list_item N/A N/A N/A list_item N/A key N/A list_item N/A _diff N/A N/A old_pipeline_definition new_pipeline_definition N/A N/A N/A 
    Return string diff of pipeline definitions.
     N/A N/A N/A old_pipeline_definition pop ResponseMetadata None N/A N/A N/A new_pipeline_definition pop ResponseMetadata None N/A diff N/A N/A difflib unified_diff N/A N/A N/A N/A json dumps old_pipeline_definition indent 4 splitlines 1 N/A N/A N/A N/A json dumps new_pipeline_definition indent 4 splitlines 1 N/A N/A N/A join diff N/A _standardize N/A N/A structure N/A N/A N/A 
    Return standardized format for lists/dictionaries.

    Lists of dictionaries are sorted by the value of the dictionary at
    its primary key ('id' or 'key'). OrderedDict's are converted to
    basic dictionaries.
     mutating_helper N/A N/A structure N/A N/A N/A N/A isinstance structure list N/A N/A N/A N/A structure sort key _id_or_key N/A each structure N/A N/A N/A mutating_helper each N/A N/A N/A isinstance structure dict N/A N/A structure N/A dict structure N/A N/A k v N/A N/A structure iteritems N/A N/A N/A mutating_helper k N/A N/A mutating_helper v N/A N/A new_structure N/A N/A copy deepcopy structure N/A N/A mutating_helper new_structure N/A new_structure N/A _pipeline_objects N/A N/A pipeline_objects_from_pillars pipeline_object_overrides N/A N/A N/A 
    Return a list of pipeline objects that compose the pipeline

    pipeline_objects_from_pillars
        The pillar key to use for lookup

    pipeline_object_overrides
        Pipeline objects to use. Will override objects read from pillars.
     N/A from_pillars N/A N/A copy deepcopy N/A N/A __salt__ N/A pillar.get pipeline_objects_from_pillars N/A N/A N/A from_pillars update pipeline_object_overrides N/A pipeline_objects N/A _standardize N/A _dict_to_list_ids from_pillars N/A pipeline_object pipeline_objects N/A N/A N/A pipeline_object N/A fields N/A _properties_from_dict N/A pipeline_object N/A fields N/A pipeline_objects N/A _parameter_objects N/A N/A parameter_objects_from_pillars parameter_object_overrides N/A N/A N/A 
    Return a list of parameter objects that configure the pipeline

    parameter_objects_from_pillars
        The pillar key to use for lookup

    parameter_object_overrides
        Parameter objects to use. Will override objects read from pillars.
     N/A from_pillars N/A N/A copy deepcopy N/A N/A __salt__ N/A pillar.get parameter_objects_from_pillars N/A N/A N/A from_pillars update parameter_object_overrides N/A parameter_objects N/A _standardize N/A _dict_to_list_ids from_pillars N/A parameter_object parameter_objects N/A N/A N/A parameter_object N/A attributes N/A _properties_from_dict N/A parameter_object N/A attributes N/A parameter_objects N/A _parameter_values N/A N/A parameter_values_from_pillars parameter_value_overrides N/A N/A N/A 
    Return a dictionary of parameter values that configure the pipeline

    parameter_values_from_pillars
        The pillar key to use for lookup

    parameter_value_overrides
        Parameter values to use. Will override values read from pillars.
     N/A from_pillars N/A N/A copy deepcopy N/A N/A __salt__ N/A pillar.get parameter_values_from_pillars N/A N/A N/A from_pillars update parameter_value_overrides N/A parameter_values N/A _standardize from_pillars N/A N/A _properties_from_dict parameter_values key_name id N/A _dict_to_list_ids N/A N/A objects N/A N/A N/A 
    Convert a dictionary to a list of dictionaries, where each element has
    a key value pair {'id': key}. This makes it easy to override pillar values
    while still satisfying the boto api.
     N/A list_with_ids N/A N/A N/A key value N/A N/A objects iteritems N/A N/A element N/A id key N/A N/A N/A element update value N/A N/A N/A list_with_ids append element N/A list_with_ids N/A _properties_from_dict N/A N/A d key_name N/A key N/A N/A 
    Transforms dictionary into pipeline object properties.

    The output format conforms to boto's specification.

    Example input:
        {
            'a': '1',
            'b': {
                'ref': '2'
            },
        }

    Example output:
        [
            {
                'key': 'a',
                'stringValue': '1',
            },
            {
                'key': 'b',
                'refValue': '2',
            },
        ]
     N/A fields N/A N/A N/A key value N/A N/A d iteritems N/A N/A N/A isinstance value dict N/A N/A N/A N/A fields append N/A key_name refValue key N/A value N/A ref N/A N/A N/A N/A fields append N/A key_name stringValue key value N/A fields N/A absent N/A N/A name region key keyid profile N/A None None None None N/A N/A 
    Ensure a pipeline with the service_name does not exist

    name
        Name of the service to ensure a data pipeline does not exist for.

    region
        Region to connect to.

    key
        Secret key to be used.

    keyid
        Access key to be used.

    profile
        A dict with region, key and keyid, or a pillar key (string)
        that contains a dict with region, key and keyid.
     N/A ret N/A name result comment changes name True N/A N/A result_pipeline_id N/A N/A __salt__ N/A boto_datapipeline.pipeline_id_from_name name region region key key keyid keyid profile profile N/A N/A error result_pipeline_id N/A N/A pipeline_id N/A result_pipeline_id N/A result N/A N/A __opts__ N/A test N/A N/A N/A ret N/A comment N/A N/A Data pipeline {0} set to be deleted. format name N/A N/A ret N/A result None N/A ret N/A N/A N/A N/A __salt__ N/A boto_datapipeline.delete_pipeline pipeline_id region region key key keyid keyid profile profile N/A N/A N/A ret N/A changes N/A old N/A pipeline_id pipeline_id N/A N/A N/A ret N/A changes N/A new None N/A N/A N/A ret N/A comment N/A N/A AWS data pipeline {0} absent. format name N/A ret N/A