FutureDetectionsAggregator

class standard_e2e.caching.segment_context.FutureDetectionsAggregator(data_path)

Bases: SegmentContextAggregator

Aggregate future detections into the current frame’s modality payload.

Parameters:

data_path (str)

process(index_df, num_workers=0, do_parallel=True, start_method='spawn')

Run the aggregator for each segment described in index_df.

Each segment is independent — disjoint npz files and no shared aggregator state — so the per-segment loop fans out across a process pool when do_parallel is enabled.

Parameters:

• index_df (DataFrame) – full per-frame index DataFrame.

• num_workers (int) – 0 → multiprocessing.cpu_count(). Pool size is capped at the number of segments so we never spawn idle workers.

• do_parallel (bool) – master toggle; False (or num_workers <= 1, or a single segment) forces a sequential loop.

• start_method (str) – "spawn" matches the frame-stage rationale — the parent process imports TensorFlow / OpenCV at module load and fork would duplicate that state into workers. Use "fork" only when callers can guarantee no global TF/cv2 state in the parent (e.g. unit tests).

Return type:

None