Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions openadapt_flow/transaction.py
Original file line number Diff line number Diff line change
Expand Up @@ -265,9 +265,7 @@ def build_effect_journal(
step is not None
and (
step.effects
or (
step.api_binding is not None and step.api_binding.effects
)
or (step.api_binding is not None and step.api_binding.effects)
)
)
)
Expand Down Expand Up @@ -300,7 +298,9 @@ def build_effect_journal(
return journal


def stamp_transaction_outcome(report: RunReport, workflow: Workflow) -> TransactionOutcome:
def stamp_transaction_outcome(
report: RunReport, workflow: Workflow
) -> TransactionOutcome:
"""Write the transaction outcome, billing metadata, and effect journal.

Called after the coarse ``execution_outcome`` is stamped (see
Expand Down
6 changes: 2 additions & 4 deletions tests/test_transaction_outcome.py
Original file line number Diff line number Diff line change
Expand Up @@ -80,8 +80,7 @@ def test_halted_before_effect_requires_verifier_established_absence():
)
report = _report("HALTED", [result])
assert (
classify_transaction_outcome(report)
is TransactionOutcome.HALTED_BEFORE_EFFECT
classify_transaction_outcome(report) is TransactionOutcome.HALTED_BEFORE_EFFECT
)


Expand Down Expand Up @@ -185,8 +184,7 @@ def test_completed_unverified_maps_through():
"COMPLETED_UNVERIFIED", [StepResult(step_id="s1", intent="x", ok=True)]
)
assert (
classify_transaction_outcome(report)
is TransactionOutcome.COMPLETED_UNVERIFIED
classify_transaction_outcome(report) is TransactionOutcome.COMPLETED_UNVERIFIED
)


Expand Down