From 7d25534def938fe63dbc8ac0a409da4f97725615 Mon Sep 17 00:00:00 2001 From: Nicholas Tindle Date: Thu, 4 Dec 2025 00:14:14 -0600 Subject: [PATCH] Refactor credential lock handling in execute_node Improved readability by formatting multi-line calls to creds_manager.acquire and the credential lock release condition. No functional changes were made. --- autogpt_platform/backend/backend/executor/manager.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/autogpt_platform/backend/backend/executor/manager.py b/autogpt_platform/backend/backend/executor/manager.py index 41b04c17cb..ee875bbf55 100644 --- a/autogpt_platform/backend/backend/executor/manager.py +++ b/autogpt_platform/backend/backend/executor/manager.py @@ -243,7 +243,9 @@ async def execute_node( ) file_name = field_data.get("name", "selected file") try: - credentials, lock = await creds_manager.acquire(user_id, cred_id) + credentials, lock = await creds_manager.acquire( + user_id, cred_id + ) creds_locks.append(lock) extra_exec_kwargs[kwarg_name] = credentials except ValueError: @@ -298,7 +300,11 @@ async def execute_node( finally: # Ensure all credentials are released even if execution fails for creds_lock in creds_locks: - if creds_lock and (await creds_lock.locked()) and (await creds_lock.owned()): + if ( + creds_lock + and (await creds_lock.locked()) + and (await creds_lock.owned()) + ): try: await creds_lock.release() except Exception as e: