in gpudirect-tcpxo/topology-scheduler/schedule-daemon.py [0:0]
def find_pod_gates(pods, prefix):
"""Finds pods with scheduling gates that starts with the prefix"""
s = set()
for pod in pods:
if pod.spec.scheduling_gates:
for g in pod.spec.scheduling_gates:
if g.name.startswith(prefix):
s.add(g.name)
return s