diff --git a/acapy_agent/wallet/anoncreds_upgrade.py b/acapy_agent/wallet/anoncreds_upgrade.py
index 4261acf0eb..3335c5ae29 100644
--- a/acapy_agent/wallet/anoncreds_upgrade.py
+++ b/acapy_agent/wallet/anoncreds_upgrade.py
@@ -472,6 +472,7 @@ async def get_rev_reg_def_upgrade_objs(
             key=lambda x: json.loads(x.value)["created_at"],
         )
     found_active = False
+    is_active = False
     for askar_issuer_rev_reg_def in askar_issuer_rev_reg_def_records:
         # active rev reg def is the oldest non-full and active rev reg def
         if (
diff --git a/scenarios/examples/restart_anoncreds_upgrade/example.py b/scenarios/examples/restart_anoncreds_upgrade/example.py
index a2241afc3b..5077090f04 100644
--- a/scenarios/examples/restart_anoncreds_upgrade/example.py
+++ b/scenarios/examples/restart_anoncreds_upgrade/example.py
@@ -162,7 +162,7 @@ def start_new_container(
     return (new_agent_container, new_agent_id)
 
 
-def stop_and_remove_container(agent_id):
+def stop_and_remove_container(client, agent_id):
     # cleanup - shut down agent (not part of docker compose)
     print(">>> shut down agent ...")
     agent_container = client.containers.get(agent_id)
@@ -313,10 +313,10 @@ async def main():
     finally:
         if alice_id and new_alice_container:
             # cleanup - shut down alice agent (not part of docker compose)
-            stop_and_remove_container(alice_id)
+            stop_and_remove_container(client, alice_id)
         if bob_id and new_bob_container:
             # cleanup - shut down bob agent (not part of docker compose)
-            stop_and_remove_container(bob_id)
+            stop_and_remove_container(client, bob_id)
 
 
 if __name__ == "__main__":