def test_header_conversion_with_valid_headers(self):
        """Headers should be correctly converted to CLI format."""
        headers = {"Authorization": "Bearer token", "User-Agent": "Test"}
        test_video_preprocessing_config = VideoPreprocessingConfig(
            modality=Modality.VIDEO,
            download_thread_count=1,
            download_header=headers,
            should_chunk=True,
            chunk_config=ChunkConfig(
                split_length=10,
                split_overlap=0
            )
        )
        with patch("marqo.inference.media_download_and_preprocess"
                   ".streaming_media_processor.StreamingMediaProcessor._fetch_file_metadata") \
                as mock_fetch_file_metadata:
            mock_fetch_file_metadata.return_value = (2971504, 10.01, Modality.VIDEO)
            streaming_media_processor_object = StreamingMediaProcessor(
                url=TestVideoUrls.VIDEO1.value, preprocessors=self.test_preprocessor,
                preprocessing_config=test_video_preprocessing_config
            )

        expected = "Authorization: Bearer token\r\nUser-Agent: Test"
        self.assertEqual(streaming_media_processor_object.media_download_header, expected)
Headers should be correctly converted to CLI format.
tests/integ_tests/inference/native_inference/media_download_and_preprocess/test_streaming_media_preprcessor.py