Skip to content

Commit

Permalink
Update to version 4.4.0 (#231)
Browse files Browse the repository at this point in the history
* Add missing poll and delay parameters to first_run
* Add str cast for command ID
* Update installation instruction for API docs
* Update to version 4.4.0

Signed-off-by: Webster Mudge <[email protected]>
  • Loading branch information
wmudge committed May 21, 2024
1 parent a5c6416 commit 1afadb0
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 4 deletions.
2 changes: 1 addition & 1 deletion docsbuild/antsibull-docs.cfg
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ collection_url = {

# The same wildcard rules and formatting rules as for collection_url apply.
collection_install = {
* = "ansible-galaxy collection install git+https://github.com/cloudera-labs/{namespace}.{name}.git"
* = "ansible-galaxy collection install {namespace}.{name}"
}

logging_cfg = {
Expand Down
2 changes: 1 addition & 1 deletion galaxy.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@

namespace: cloudera
name: cluster
version: 4.3.1
version: 4.4.0
readme: README.md
authors:
- Webster Mudge @wmudge
Expand Down
2 changes: 1 addition & 1 deletion plugins/module_utils/cm_utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -492,7 +492,7 @@ def wait_command(self, command: ApiCommand, polling: int = 10, delay: int = 5):
poll_count = 0
while command.active:
if poll_count > polling:
self.module.fail_json(msg="Command timeout: " + command.id)
self.module.fail_json(msg="Command timeout: " + str(command.id))
sleep(delay)
poll_count += 1
command = CommandsResourceApi(self.api_client).read_command(command.id)
Expand Down
4 changes: 3 additions & 1 deletion plugins/modules/cluster.py
Original file line number Diff line number Diff line change
Expand Up @@ -816,7 +816,9 @@ def process(self):
# If newly created or created by not yet initialize
if not existing or existing.entity_status == "NONE":
first_run = self.cluster_api.first_run(cluster_name=self.name)
self.wait_command(first_run)
self.wait_command(
first_run, polling=self.timeout, delay=self.delay
)
# Start the existing and previously initialized cluster
else:
start = self.cluster_api.start_command(cluster_name=self.name)
Expand Down

0 comments on commit 1afadb0

Please sign in to comment.