Skip to content

Commit 971be31

Browse files
authored
Add recipes parameter to cloudera.cloud.datalake (#107)
Signed-off-by: Jim Enright <jenright@cloudera.com>
1 parent 2de076e commit 971be31

File tree

1 file changed

+20
-1
lines changed

1 file changed

+20
-1
lines changed

plugins/modules/datalake.py

Lines changed: 20 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -139,6 +139,20 @@
139139
type: bool
140140
required: False
141141
default: False
142+
recipes:
143+
description:
144+
- Recipes that will be attached on the datalake instances groups
145+
type: array
146+
elements: dict
147+
required: False
148+
contains:
149+
instanceGroupName:
150+
description: Datalake instance/host group group name, e.g. `master` or `idbroker`.
151+
type: str
152+
recipeNames:
153+
description: Names of the recipes
154+
type: array
155+
elements: str
142156
multi_az:
143157
description:
144158
- (AWS) Flag indicating if the datalake is deployed across multi-availability zones.
@@ -411,6 +425,7 @@ def __init__(self, module):
411425
self.timeout = self._get_param('timeout')
412426
self.force = self._get_param('force')
413427
self.raz = self._get_param("raz")
428+
self.recipes = self._get_param("recipes")
414429
self.multi_az = self._get_param("multi_az")
415430

416431
# Initialize the return values
@@ -571,6 +586,9 @@ def _configure_payload(self, environment):
571586
elif environment['cloudPlatform'] == 'AWS':
572587
payload.update(multiAz=self.multi_az)
573588

589+
if self.recipes:
590+
payload.update(recipes=self.recipes)
591+
574592
if self.tags is not None:
575593
payload['tags'] = list()
576594
for k in self.tags:
@@ -651,7 +669,8 @@ def main():
651669
delay=dict(required=False, type='int', aliases=['polling_delay'], default=15),
652670
timeout=dict(required=False, type='int', aliases=['polling_timeout'], default=3600),
653671
raz=dict(required=False, type="bool", default=False),
654-
multi_az=dict(required=False, type="bool", default=False)
672+
multi_az=dict(required=False, type="bool", default=False),
673+
recipes=dict(required=False, type="list", elements="dict",options=dict(instanceGroupName=dict(required=True,type="str"),recipeNames=dict(required=True,type="list",elements="str")))
655674
),
656675
supports_check_mode=True
657676
)

0 commit comments

Comments
 (0)