Skip to content

Commit 95bc51e

Browse files
author
Вадим Козыревский
committed
Fix pre-commit errors
1 parent cd0b0f7 commit 95bc51e

2 files changed

Lines changed: 4 additions & 3 deletions

File tree

examples/saga_fastapi_sse.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -464,7 +464,8 @@ async def generate_sse():
464464

465465
# Execute saga with saga_id for persistence
466466
async with saga.transaction(
467-
context=context, saga_id=saga_id
467+
context=context,
468+
saga_id=saga_id,
468469
) as transaction:
469470
async for step_result in transaction:
470471
completed_steps += 1

examples/saga_recovery.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -302,7 +302,7 @@ async def cancel_shipment(self, shipment_id: str) -> None:
302302
tracking_number = self._shipments[shipment_id]
303303
del self._shipments[shipment_id]
304304
logger.info(
305-
f" ↻ Cancelled shipment {shipment_id} (tracking: {tracking_number})"
305+
f" ↻ Cancelled shipment {shipment_id} (tracking: {tracking_number})",
306306
)
307307

308308

@@ -565,7 +565,7 @@ async def simulate_interrupted_saga() -> tuple[uuid.UUID, MemorySagaStorage]:
565565
if step_name == "ReserveInventoryStep":
566566
print("\n💥 SIMULATED SERVER CRASH!")
567567
print(
568-
" (In reality: server restart, network failure, timeout, etc.)"
568+
" (In reality: server restart, network failure, timeout, etc.)",
569569
)
570570
print(" Saga state has been persisted to storage.")
571571
print(" Current state: RUNNING, 1 step completed")

0 commit comments

Comments
 (0)