Add import of DF Custom Flows to runtime role

docs/configuration.yml

@@ -37,6 +37,13 @@ de:
   force_delete:
   vc_suffix:
 df:
+  readyflows:
+    - flow_name:
+  customflows:
+    - flow_name:
+      file:
+      description:
+      comments:
   suffix:
   min_k8s_nodes:
   max_k8s_nodes:

roles/runtime/defaults/main.yml

@@ -87,6 +87,7 @@ run__df_terminate_deployments:      "{{ df.terminate_deployments | default(True)
 run__df_tags:                       "{{ df.tags | default(common__tags) }}"
 run__df_deployments:                "{{ df.deployments | default([]) }}"
 run__df_readyflows:                 "{{ df.readyflows | default([]) }}"
+run__df_customflows:                "{{ df.customflows | default([]) }}"
 run__df_delete_readyflows:          "{{ df.delete_imported_readyflows | default(False) }}"
 
 # Deploy

roles/runtime/tasks/setup_base.yml

@@ -223,6 +223,19 @@
     loop_var: __df_readyflow_item
     label: "{{ __df_readyflow_item.flow_name }}"
 
+- name: Ensure requested CDP DF CustomFlows are imported
+  when: run__include_df
+  tags: df
+  cloudera.cloud.df_customflow:
+    name: "{{ __df_customflow_item.flow_name }}"
+    file: "{{ __df_customflow_item.file }}"
+    description: "{{ __df_customflow_item.description | default('') }}"
+    comments: "{{ __df_customflow_item.comments | default('') }}"
+  loop: "{{ run__df_customflows }}"
+  loop_control:
+    loop_var: __df_customflow_item
+    label: "{{ __df_customflow_item.flow_name }}"
+
 - name: Create CDP DF Deployments
   when:
     - run__include_df