fix: fix quality checks

openedx · Mar 21, 2024 · 317443c · 317443c
1 parent 9de5ae5
commit 317443c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/edx_event_bus_kafka/internal/producer.py b/edx_event_bus_kafka/internal/producer.py
@@ -316,7 +316,7 @@ def send(
             # would never get a delivery callback. That's why there's also a thread calling
             # poll(0) on a regular interval (see `poll_indefinitely`).
             self.producer.poll(0)
-        except Exception as e:  # pylint: disable=broad-except
+        except Exception as e:
             # Errors caused by the produce call should be handled by the on_delivery callback.
             # Here we might expect serialization errors, or any errors from preparing to produce.
             record_producing_error(e, context)

diff --git a/edx_event_bus_kafka/management/commands/produce_event.py b/edx_event_bus_kafka/management/commands/produce_event.py
@@ -64,5 +64,5 @@ def handle(self, *args, **options):
                 event_metadata=EventsMetadata(event_type=event_type),
             )
             producer.prepare_for_shutdown()  # otherwise command may exit before delivery is complete
-        except Exception as e:
+        except Exception:
             logger.exception("Error producing Kafka event")