Skip to content

Commit

Permalink
[pre-commit.ci] auto fixes from pre-commit.com hooks
Browse files Browse the repository at this point in the history
for more information, see https://pre-commit.ci
  • Loading branch information
pre-commit-ci[bot] committed Nov 17, 2023
1 parent 816c55f commit addf332
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 12 deletions.
4 changes: 1 addition & 3 deletions enterprise_gateway/client/gateway_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -218,9 +218,7 @@ def execute(self, code, timeout=REQUEST_TIMEOUT):
): # We timed out. If post idle, its ok, else make mention of it
if not post_idle:
self.log.warning(
"Unexpected timeout occurred for msg_id: {} - no 'idle' status received!".format(
msg_id
)
f"Unexpected timeout occurred for msg_id: {msg_id} - no 'idle' status received!"
)
break

Expand Down
8 changes: 2 additions & 6 deletions enterprise_gateway/services/processproxies/conductor.py
Original file line number Diff line number Diff line change
Expand Up @@ -189,9 +189,7 @@ def _update_notebook_master_rest_url(self, env_dict: dict) -> None:
response = None
except Exception as e:
self.log.warning(
"Getting instance group with cmd '{}' failed with exception: '{}'. Continuing...".format(
cmd, e
)
f"Getting instance group with cmd '{cmd}' failed with exception: '{e}'. Continuing..."
)
return

Expand Down Expand Up @@ -623,9 +621,7 @@ def _kill_app_by_driver_id(self, driver_id: str):
response = json.loads(output) if output else None
except Exception as e:
self.log.warning(
"Termination of application with cmd '{}' failed with exception: '{}'. Continuing...".format(
cmd, e
)
f"Termination of application with cmd '{cmd}' failed with exception: '{e}'. Continuing..."
)
self.log.debug(f"Kill response: {response}")
return response
Expand Down
4 changes: 1 addition & 3 deletions enterprise_gateway/services/processproxies/yarn.py
Original file line number Diff line number Diff line change
Expand Up @@ -581,9 +581,7 @@ def _kill_app_by_id(self, app_id: str) -> Response:
response = self.resource_mgr.cluster_application_kill(application_id=app_id)
except Exception as e:
self.log.warning(
"Termination of application '{}' failed with exception: '{}'. Continuing...".format(
app_id, e
)
f"Termination of application '{app_id}' failed with exception: '{e}'. Continuing..."
)

return response

0 comments on commit addf332

Please sign in to comment.