diff --git a/README.rst b/README.rst index 4da7309..33cf226 100644 --- 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 index eecf0e5..e8cd004 100644 --- a/edx_arch_experiments/scripts/republish_failed_events.py +++ b/edx_arch_experiments/scripts/republish_failed_events.py @@ -29,7 +29,7 @@ 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 @@ -37,7 +37,7 @@ @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: