Invoke teardowns of already filled fixtures on fixture errors

Author: gerlero

pytest_asyncio_cooperative/fixtures.py

@@ -69,15 +69,26 @@ async def fill_fixtures(item):
 
     # Fill fixtures concurrently
     fill_results = await asyncio.gather(
-        *(fill_fixture_fixtures(item._fixtureinfo, fixture, item) for fixture in fixtures)
+        *(fill_fixture_fixtures(item._fixtureinfo, fixture, item) for fixture in fixtures),
+        return_exceptions=True
     )
 
-    for ((value, extra_teardowns), is_autouse) in zip(fill_results, are_autouse):
+    exceptions = []
+    for result, is_autouse in zip(fill_results, are_autouse):
+        if isinstance(result, BaseException):
+            exceptions.append(result)
+            continue
+
+        value, extra_teardowns = result
         teardowns.extend(extra_teardowns)
 
         if not is_autouse:
             fixture_values.append(value)
 
+    if exceptions:
+        await do_teardowns(teardowns)
+        raise exceptions[0]
+
     # Slight hack to stop the regular fixture logic from running
     item.fixturenames = []
 
@@ -93,9 +104,15 @@ async def _fill_fixture_fixtures(_fixtureinfo, fixture, item):
         except Ignore:
             continue
 
-        value, teardowns = await fill_fixture_fixtures(_fixtureinfo, dep_fixture, item)
+        try:
+            value, teardowns = await fill_fixture_fixtures(_fixtureinfo, dep_fixture, item)
+        except:
+            await do_teardowns(all_teardowns)
+            raise
+
         values.append(value)
         all_teardowns.extend(teardowns)
+
     return values, all_teardowns