def _unschedulable_due_to_pvc()

in ingestion-edge/ingestion_edge/flush_manager.py [0:0]

• 15 lines of code
• 11 McCabe index (conditional complexity)

def _unschedulable_due_to_pvc(pod: V1Pod):
    return (
        pod.status
        and pod.status.phase == "Pending"
        and any(
            condition.reason == "Unschedulable"
            and condition.message
            and condition.message.startswith('persistentvolumeclaim "')
            and condition.message.endswith('" not found')
            for condition in (pod.status.conditions or [])
            if condition
        )
        and pod.metadata.owner_references
        and any(ref.kind == "StatefulSet" for ref in pod.metadata.owner_references)
    )