utilities for video streaming

[deigen]

pyav-based and streaming-related utilities and changes for the following:

• stream_utils.py with
  • classes to interface with streams of byte chunks using file-like objects read()
  • readahead iterator (apply next() ahead of yield using single bg thread)
  • parallel map (apply function to next n of a stream at a time, yield in order)
• video_utils.py with
  • stream and decode from rtsp url
  • decode downloaded video (todo item to check for streamability with head bytes)
  • stream from byte chunks, incoming in grpc stream or streaming url download
  • container conversion, e.g. from mp4 to mpegts, to upload videos in a streamable container so they can be processed immediately (mp4 requires downloading the entire file first before decoding, since some info is at the end; mpegts can stream using the same encodings as the original file, though there are some details around exactly matching timestamps)
• streaming url downloading
• in StreamModelOutputs run ensure_urls_downloaded as stream comes in, do not play stream to end
• make ensure_urls_downloaded() optional with flag, move into model
• made getting model_info params in predict calls thread-safe

[github-actions]

Package	Line Rate	Health
clarifai	43%	❌
clarifai.cli	67%	➖
clarifai.client	71%	➖
clarifai.client.auth	74%	➖
clarifai.constants	100%	✔
clarifai.datasets	100%	✔
clarifai.datasets.export	80%	✔
clarifai.datasets.upload	75%	➖
clarifai.datasets.upload.loaders	37%	❌
clarifai.models	100%	✔
clarifai.modules	0%	❌
clarifai.rag	72%	➖
clarifai.runners	12%	❌
clarifai.runners.models	59%	➖
clarifai.runners.utils	65%	➖
clarifai.schema	100%	✔
clarifai.urls	80%	✔
clarifai.utils	73%	➖
clarifai.utils.evaluation	67%	➖
clarifai.workflows	94%	✔
Summary	68% (4658 / 6861)	➖

Minimum allowed line rate is 50%