Fix lint issues

Author: DylanRussell

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/_log_exporter/__init__.py

@@ -138,15 +138,15 @@ def _export(self, serialized_data: bytes, timeout_sec: float):
                 url=self._endpoint,
                 data=data,
                 verify=self._certificate_file,
-                timeout=timeout_sec
+                timeout=timeout_sec,
                 cert=self._client_cert,
             )
         except ConnectionError:
             resp = self._session.post(
                 url=self._endpoint,
                 data=data,
                 verify=self._certificate_file,
-                timeout=timeout_sec
+                timeout=timeout_sec,
                 cert=self._client_cert,
             )
         return resp

opentelemetry-sdk/src/opentelemetry/sdk/_logs/_internal/export/__init__.py

@@ -92,13 +92,6 @@ def shutdown(self):
         Called when the SDK is shut down.
         """
 
-    @abc.abstractmethod
-    def force_flush(self, timeout_millis: int = 30000) -> bool:
-        """Hint to ensure that the export of any spans the exporter has received
-        prior to the call to ForceFlush SHOULD be completed as soon as possible, preferably
-        before returning from this method.
-        """
-
 
 class ConsoleLogExporter(LogExporter):
     """Implementation of :class:`LogExporter` that prints log records to the
@@ -127,7 +120,6 @@ def export(self, batch: Sequence[LogData]):
     def shutdown(self):
         pass
 
-
 class SimpleLogRecordProcessor(LogRecordProcessor):
     """This is an implementation of LogRecordProcessor which passes
     received logs in the export-friendly LogData representation to the

opentelemetry-sdk/src/opentelemetry/sdk/trace/export/__init__.py

@@ -57,7 +57,6 @@ class SpanExportResult(Enum):
     FAILURE = 1
 
 
-
 class SpanExporter(abc.ABC):
     """Interface for exporting spans.
 
@@ -91,7 +90,6 @@ def shutdown(self) -> None:
         Called when the SDK is shut down.
         """
 
-    @abc.abstractmethod
     def force_flush(self, timeout_millis: int = 30000) -> bool:
         """Hint to ensure that the export of any spans the exporter has received
         prior to the call to ForceFlush SHOULD be completed as soon as possible, preferably
@@ -517,11 +515,15 @@ def __init__(
         self.formatter = formatter
         self.service_name = service_name
 
+    # pylint: disable=arguments-differ
     def export(self, spans: typing.Sequence[ReadableSpan]) -> SpanExportResult:
         for span in spans:
             self.out.write(self.formatter(span))
         self.out.flush()
         return SpanExportResult.SUCCESS
 
-    def force_flush(self, timeout_millis: int = 30000) -> bool:
+    def force_flush(self, timeout_millis: int = 30000):
         return True
+
+    def shutdown(self):
+        pass

opentelemetry-sdk/src/opentelemetry/sdk/trace/export/in_memory_span_exporter.py

@@ -42,6 +42,7 @@ def get_finished_spans(self) -> typing.Tuple[ReadableSpan, ...]:
         with self._lock:
             return tuple(self._finished_spans)
 
+    # pylint: disable=arguments-differ
     def export(self, spans: typing.Sequence[ReadableSpan]) -> SpanExportResult:
         """Stores a list of spans in memory."""
         if self._stopped:

opentelemetry-sdk/tests/trace/export/test_export.py

@@ -60,6 +60,7 @@ def __init__(
         self.export_timeout = export_timeout_millis / 1e3
         self.export_event = export_event
 
+    # pylint: disable=arguments-differ
     def export(self, spans: trace.Span) -> export.SpanExportResult:
         if (
             self.max_export_batch_size is not None
@@ -75,6 +76,9 @@ def export(self, spans: trace.Span) -> export.SpanExportResult:
     def shutdown(self):
         self.is_shutdown = True
 
+    def force_flush(self, timeout_millis: int = 30000) -> bool:
+        return True
+
 
 class TestSimpleSpanProcessor(unittest.TestCase):
     def test_simple_span_processor(self):