Event streaming issue

[asoral]

• I setup event producer, which sets up the event consumer on the other instance.
• It did work for the first time then I realized I have to set some defaults and thus create mapping
• Which I did and since then it is not working. I changed nothing else.
• Now I tried following all the steps again but it does work anymore and gives me this error below:

Title frappe.event_streaming.doctype.event_producer.event_producer.pull_from_node Error Traceback with variables (most recent call last): File "apps/frappe/frappe/utils/background_jobs.py", line 188, in execute_job retval = method(**kwargs) site = 'dexciss.frappe.cloud' method = <function pull_from_node at 0x7fae4c3dab90> event = None job_name = 'frappe.event_streaming.doctype.event_producer.event_producer.pull_from_node' kwargs = {'event_producer': 'http://erp.teststream.com'} user = 'teststream@dexciss.com' is_async = True retry = 0 retval = None method_name = 'frappe.event_streaming.doctype.event_producer.event_producer.pull_from_node' before_job_task = 'frappe.monitor.start' File "apps/frappe/frappe/event_streaming/doctype/event_producer/event_producer.py", line 234, in pull_from_node event_producer = frappe.get_doc("Event Producer", event_producer) event_producer = 'http://erp.teststream.com' File "apps/frappe/frappe/__init__.py", line 1185, in get_doc doc = frappe.model.document.get_doc(*args, **kwargs) args = ('Event Producer', 'http://erp.teststream.com') kwargs = {} frappe = <module 'frappe' from 'apps/frappe/frappe/__init__.py'> File "apps/frappe/frappe/model/document.py", line 74, in get_doc return controller(*args, **kwargs) args = ('Event Producer', 'http://erp.teststream.com') kwargs = {} doctype = 'Event Producer' controller = <class 'frappe.event_streaming.doctype.event_producer.event_producer.EventProducer'> File "apps/frappe/frappe/model/document.py", line 106, in __init__ self.load_from_db() self = <EventProducer: http://erp.teststream.com> args = ('Event Producer', 'http://erp.teststream.com') kwargs = {} __class__ = <class 'frappe.model.document.Document'> File "apps/frappe/frappe/model/document.py", line 149, in load_from_db frappe.throw( self = <EventProducer: http://erp.teststream.com> d = None __class__ = <class 'frappe.model.document.Document'> File "apps/frappe/frappe/__init__.py", line 526, in throw msgprint( msg = 'Event Producer http://erp.teststream.com not found' exc = <class 'frappe.exceptions.DoesNotExistError'> title = None is_minimizable = False wide = False as_list = False File "apps/frappe/frappe/__init__.py", line 494, in msgprint _raise_exception() title = None as_table = False as_list = False indicator = 'red' alert = False primary_action = None is_minimizable = False wide = False sys = <module 'sys' (built-in)> out = {'message': 'Event Producer http://erp.teststream.com not found', 'title': 'Message', 'indicator': 'red', 'raise_exception': 1} _raise_exception = <function msgprint.<locals>._raise_exception at 0x7fae4c404e50> _strip_html_tags = <functools._lru_cache_wrapper object at 0x7fae4762ce00> inspect = <module 'inspect' from '/usr/lib/python3.10/inspect.py'> msg = 'Event Producer http://erp.teststream.com not found' raise_exception = <class 'frappe.exceptions.DoesNotExistError'> strip_html_tags = <function strip_html_tags at 0x7fae4e8f6200> File "apps/frappe/frappe/__init__.py", line 443, in _raise_exception raise raise_exception(msg) inspect = <module 'inspect' from '/usr/lib/python3.10/inspect.py'> msg = 'Event Producer http://erp.teststream.com not found' raise_exception = <class 'frappe.exceptions.DoesNotExistError'> frappe.exceptions.DoesNotExistError: Event Producer http://erp.teststream.com not found

[asoral]

A thing to note in the error above is the event producer HTTP://erp.teststream.com is actually https://erp.teststreams.com. With an "s"