lint fixes

Author: Akochavi

instrumentation/opentelemetry-instrumentation-celery/src/opentelemetry/instrumentation/celery/__init__.py

@@ -191,10 +191,7 @@ def _trace_postrun(self, *args, **kwargs):
         activation.__exit__(None, None, None)
         utils.detach_span(task, task_id)
         self.update_task_start_time(task_id)
-        labels = {
-            'task': task.name,
-            'worker': task.request.hostname
-        }
+        labels = {"task": task.name, "worker": task.request.hostname}
         self._record_histograms(task_id, labels)
 
     def _trace_before_publish(self, *args, **kwargs):
@@ -291,13 +288,18 @@ def _trace_retry(*args, **kwargs):
 
     def update_task_start_time(self, task_id):
         cur_time = default_timer()
-        elapsed_time = cur_time - self.task_id_to_start_time[
-            task_id] if task_id in self.task_id_to_start_time else cur_time
+        elapsed_time = (
+            cur_time - self.task_id_to_start_time[task_id]
+            if task_id in self.task_id_to_start_time
+            else cur_time
+        )
         self.task_id_to_start_time[task_id] = elapsed_time
 
     def _record_histograms(self, task_id, metric_attributes):
         self.metrics["flower.task.runtime.seconds"].record(
-            self.task_id_to_start_time.get(task_id), attributes=metric_attributes)
+            self.task_id_to_start_time.get(task_id),
+            attributes=metric_attributes,
+        )
 
     def create_celery_metrics(self, meter) -> None:
         self.metrics = {

instrumentation/opentelemetry-instrumentation-celery/tests/test_metrics.py

@@ -17,8 +17,9 @@
 class TestMetrics(TestBase):
     def setUp(self):
         super().setUp()
-        self._worker = app.Worker(app=app, pool="solo", concurrency=1,
-                                  hostname='celery@akochavi')
+        self._worker = app.Worker(
+            app=app, pool="solo", concurrency=1, hostname="celery@akochavi"
+        )
         self._thread = threading.Thread(target=self._worker.start)
         self._thread.daemon = True
         self._thread.start()
@@ -95,15 +96,13 @@ def test_basic_metric(self):
 
         task_runtime = metrics[0]
         print(task_runtime)
-        self.assertEqual(
-            task_runtime.name, "flower.task.runtime.seconds"
-        )
+        self.assertEqual(task_runtime.name, "flower.task.runtime.seconds")
         self.assert_metric_expected(
             task_runtime,
             task_runtime_estimated,
             {
-                'task': 'tests.celery_test_tasks.task_add',
-                'worker': 'celery@akochavi',
+                "task": "tests.celery_test_tasks.task_add",
+                "worker": "celery@akochavi",
             },
             est_delta=200,
         )