<#743 add phase runtimes to action details>
Pull r...
# flyte-githuba
acoustic-carpenter-78188
03/03/2026, 11:31 PM#743 add phase runtimes to action details
Pull request opened by dansola
Test on this run: https://demo.hosted.unionai.cloud/v2/domain/development/project/daniel/runs/rhn8t2tsh8q5r577797b
Script:
Copy code
def test_phase_transitions(run_name: str, action_name: str):
"""Test phase transition functionality with a real action."""
print(f"Fetching action: run={run_name}, action={action_name}")
print("-" * 80)
# Get action details directly (ActionDetails.get is sync via @syncify)
details = ActionDetails.get(run_name=run_name, name=action_name)
print(f"✓ Got action: {action_name}")
print(f" Phase: {details.phase}")
print()
print(f"✓ Got action details")
print(f" Total runtime: {details.runtime.total_seconds():.2f}s")
print(f" Attempts: {details.attempts}")
print()
# Test the new functionality
print("=" * 80)
print("TESTING NEW PHASE TRANSITION FUNCTIONALITY")
print("=" * 80)
print()
# Test 1: Get phase transitions
print("1. Testing get_phase_transitions():")
transitions = details.get_phase_transitions()
if transitions:
print(f" ✓ Found {len(transitions)} phase transitions:")
for t in transitions:
duration_sec = t.duration.total_seconds()
end_str = t.end_time.isoformat() if t.end_time else "ongoing"
print(f" - {t.phase.value:25s} {duration_sec:8.2f}s ({t.start_time.isoformat()} -> {end_str})")
else:
print(" ⚠ No phase transitions found (might be an older action or local execution)")
print()
# Test 2: Phase durations property
print("2. Testing phase_durations property:")
durations = details.phase_durations
if durations:
print(f" ✓ Found {len(durations)} phases:")
for phase, duration in durations.items():
print(f" - {phase.value}: {duration.total_seconds():.2f}s")
else:
print(" ⚠ No phase durations available")
print()
# Test 3: Individual phase properties
print("3. Testing individual phase properties:")
phase_checks = [
("queued_time", details.queued_time),
("waiting_for_resources_time", details.waiting_for_resources_time),
("initializing_time", details.initializing_time),
("running_time", details.running_time),
]
for prop_name, value in phase_checks:
if value is not None:
print(f" ✓ {prop_name:30s} = {value.total_seconds():8.2f}s")
else:
print(f" - {prop_name:30s} = None (phase not encountered)")
print()
# Test 4: Rich representation
print("4. Testing rich representation (shows phase_breakdown):")
print("-" * 80)
print(details)
print("-" * 80)
print()
# Verify totals match
if durations:
total_from_phases = sum(d.total_seconds() for d in durations.values())
total_runtime = details.runtime.total_seconds()
diff = abs(total_from_phases - total_runtime)
print(f"5. Verification:")
print(f" Total from phases: {total_from_phases:.2f}s")
print(f" Total runtime: {total_runtime:.2f}s")
print(f" Difference: {diff:.2f}s")
if diff < 1.0: # Allow 1s difference due to rounding
print(" ✓ Totals match!")
else:
print(" ⚠ Totals don't match exactly (might be expected depending on phase transitions)")
print()
print("=" * 80)
print("✓ ALL TESTS COMPLETED")
print("=" * 80)acoustic-carpenter-78188
03/04/2026, 1:06 AM