feat: abstract out producer creation (#413)

edx · Aug 25, 2023 · c5cfc5e · c5cfc5e
1 parent 313a90d
commit c5cfc5e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/README.rst b/README.rst
@@ -4,13 +4,13 @@ edx-arch-experiments
 |pypi-badge| |ci-badge| |codecov-badge| |pyversions-badge|
 |license-badge|
 
-A plugin to include applications under development by the architecture team at 2U.
+A plugin to include applications under development by and useful utility scripts for the architecture team at 2U.
 
 Overview
 ------------------------
 
 This plugin is meant to house experimental and in-development applications from the edX architecture team at 2U that are either not appropriate (i.e. 2U-specific) or not yet ready for community consumption.
-
+It also includes some one-off scripts meant to reduce toil for the team.
 
 Development Workflow
 --------------------

diff --git a/edx_arch_experiments/scripts/republish_failed_events.py b/edx_arch_experiments/scripts/republish_failed_events.py
@@ -29,15 +29,15 @@
 from ast import literal_eval
 
 import click
-from edx_event_bus_kafka.internal.producer import create_producer
+from openedx_events.event_bus import get_producer
 from openedx_events.tooling import EventsMetadata, OpenEdxPublicSignal, load_all_signals
 
 
 @click.command()
 @click.option('--filename', type=click.Path(exists=True))
 def read_and_send_events(filename):
     load_all_signals()
-    producer = create_producer()
+    producer = get_producer()
     try:
         log_columns = ['initial_topic', 'event_type', 'event_data_as_json', 'event_key_field', 'event_metadata_as_json']
         with open(filename) as log_file: