@@ -110,28 +110,36 @@ def _make_batch_config(
110110 )
111111
112112 def test_batch_processor_default_schedule_delay (self ):
113- processor = _create_batch_log_record_processor (self ._make_batch_config ())
113+ processor = _create_batch_log_record_processor (
114+ self ._make_batch_config ()
115+ )
114116 self .assertEqual (
115117 processor ._batch_processor ._schedule_delay_millis ,
116118 _DEFAULT_SCHEDULE_DELAY_MILLIS ,
117119 )
118120
119121 def test_batch_processor_default_export_timeout (self ):
120- processor = _create_batch_log_record_processor (self ._make_batch_config ())
122+ processor = _create_batch_log_record_processor (
123+ self ._make_batch_config ()
124+ )
121125 self .assertEqual (
122126 processor ._batch_processor ._export_timeout_millis ,
123127 _DEFAULT_EXPORT_TIMEOUT_MILLIS ,
124128 )
125129
126130 def test_batch_processor_default_max_queue_size (self ):
127- processor = _create_batch_log_record_processor (self ._make_batch_config ())
131+ processor = _create_batch_log_record_processor (
132+ self ._make_batch_config ()
133+ )
128134 self .assertEqual (
129135 processor ._batch_processor ._max_queue_size ,
130136 _DEFAULT_MAX_QUEUE_SIZE ,
131137 )
132138
133139 def test_batch_processor_default_max_export_batch_size (self ):
134- processor = _create_batch_log_record_processor (self ._make_batch_config ())
140+ processor = _create_batch_log_record_processor (
141+ self ._make_batch_config ()
142+ )
135143 self .assertEqual (
136144 processor ._batch_processor ._max_export_batch_size ,
137145 _DEFAULT_MAX_EXPORT_BATCH_SIZE ,
@@ -163,10 +171,14 @@ def test_batch_processor_explicit_max_export_batch_size(self):
163171 processor = _create_batch_log_record_processor (
164172 self ._make_batch_config (max_export_batch_size = 128 )
165173 )
166- self .assertEqual (processor ._batch_processor ._max_export_batch_size , 128 )
174+ self .assertEqual (
175+ processor ._batch_processor ._max_export_batch_size , 128
176+ )
167177
168178 def test_batch_processor_uses_console_exporter (self ):
169- processor = _create_batch_log_record_processor (self ._make_batch_config ())
179+ processor = _create_batch_log_record_processor (
180+ self ._make_batch_config ()
181+ )
170182 self .assertIsInstance (
171183 processor ._batch_processor ._exporter , ConsoleLogRecordExporter
172184 )
@@ -180,9 +192,7 @@ def test_simple_processor_uses_console_exporter(self):
180192 self .assertIsInstance (processor ._exporter , ConsoleLogRecordExporter )
181193
182194 def test_batch_processor_dispatched_from_processor_config (self ):
183- config = LogRecordProcessorConfig (
184- batch = self ._make_batch_config ()
185- )
195+ config = LogRecordProcessorConfig (batch = self ._make_batch_config ())
186196 processor = _create_log_record_processor (config )
187197 self .assertIsInstance (processor , BatchLogRecordProcessor )
188198
@@ -303,7 +313,9 @@ def test_otlp_http_exporter_headers(self):
303313 ):
304314 config = LogRecordExporterConfig (
305315 otlp_http = OtlpHttpExporterConfig (
306- headers = [NameStringValuePair (name = "x-api-key" , value = "secret" )]
316+ headers = [
317+ NameStringValuePair (name = "x-api-key" , value = "secret" )
318+ ]
307319 )
308320 )
309321 _create_log_record_exporter (config )
@@ -346,7 +358,8 @@ def test_limits_logs_warning(self):
346358 limits = LogRecordLimitsConfig (attribute_count_limit = 64 ),
347359 )
348360 with self .assertLogs (
349- "opentelemetry.sdk._configuration._logger_provider" , level = "WARNING"
361+ "opentelemetry.sdk._configuration._logger_provider" ,
362+ level = "WARNING" ,
350363 ) as cm :
351364 create_logger_provider (config )
352365 self .assertTrue (
0 commit comments