Initial pipeline-execution resource (#174)

* initial pipeline-execution resource

* Provide test image

* update crds for pipeline execution

* update image

* update e2e test

* use small pipeline and add hook for adoption

* use processing job for pipeline-execution test

* regen with instance groups

* test for last modified time in e2e

* regen with adoption

Author: ryansteakley

apis/v1alpha1/ack-generate-metadata.yaml

@@ -1,13 +1,13 @@
 ack_generate_info:
-  build_date: "2022-12-01T04:13:07Z"
+  build_date: "2022-12-06T04:24:52Z"
   build_hash: 6e2ffbc3b16a30ac59be6719918c601c2c864064
   go_version: go1.19.1
   version: v0.20.1-3-g6e2ffbc-dirty
-api_directory_checksum: 0db1fd575ff46e8ba76499d850396be289955ea6
+api_directory_checksum: d1a8286cb85155b185875aae9e3a72beaf720595
 api_version: v1alpha1
 aws_sdk_go_version: v1.44.93
 generator_config_info:
-  file_checksum: c3c79f9a3bb0da1c242c37ada3a10b07ab836653
+  file_checksum: afd4f10e7b9ed9b76e24dfcfefb646c024b03271
   original_file_name: generator.yaml
 last_modification:
   reason: API generation

apis/v1alpha1/enums.go

@@ -16,7 +16,67 @@ operations:
   StopHyperParameterTuningJob:
     operation_type: Delete
     resource_name: HyperParameterTuningJob
+  StartPipelineExecution:
+    operation_type: Create
+    resource_name: PipelineExecution
+  StopPipelineExecution:
+    operation_type: Delete
+    resource_name: PipelineExecution
 resources:
+  PipelineExecution:
+    # Resource state/status can have automatic retry-policy
+    # Need to reconcile to catch these state/status changes
+    reconcile: 
+      requeue_on_success_seconds: 60
+    hooks:
+      sdk_read_one_pre_set_output:
+        code: rm.customSetSpec(ko,resp)
+      sdk_read_one_post_set_output:
+        code: rm.customSetOutput(&resource{ko})
+      sdk_delete_pre_build_request:
+        template_path: pipeline_execution/sdk_delete_pre_build_request.go.tpl
+      sdk_delete_post_request:
+        template_path: common/sdk_delete_post_request.go.tpl
+      sdk_update_post_set_output:
+        code: rm.customSetOutput(&resource{ko})
+    fields:
+      PipelineExecutionStatus:
+        is_read_only: true
+        print:
+          name: STATUS
+        from:
+          operation: DescribePipelineExecution
+          path: PipelineExecutionStatus
+      FailureReason:
+        is_read_only: true
+        print:
+          name: FAILURE-REASON
+          priority: 1
+        from:
+          operation: DescribePipelineExecution
+          path: FailureReason
+      CreationTime:
+        is_read_only: true
+        from:
+          operation: DescribePipelineExecution
+          path: CreationTime
+      LastModifiedTime:
+        is_read_only: true
+        from:
+          operation: DescribePipelineExecution
+          path: LastModifiedTime
+    exceptions:
+      errors:
+        404:
+          code: ResourceNotFound
+          message_suffix: does not exist
+      terminal_codes:
+        - InvalidParameterCombination
+        - InvalidParameterValue
+        - MissingParameter
+        - ResourceNotFound
+    tags:
+      ignore: true
   Model:
     hooks:
       delta_pre_compare:
@@ -922,8 +982,7 @@ ignore:
       - ExecutionRoleIdentityConfig
       - HyperParameterTuningResourceConfig
       - InstanceMetadataServiceConfiguration
-      - InstanceGroups
-      - InstanceGroupNames
     field_paths:
+      - StartPipelineExecutionInput.ClientRequestToken
       - CreatePipelineInput.ClientRequestToken
       - CreatePipelineInput.PipelineDefinitionS3Location