From 6f3afa18cb21c424dcc82abebf8173c3ff40dfe5 Mon Sep 17 00:00:00 2001 From: Rucha Mahabal Date: Fri, 11 Oct 2019 10:49:19 +0530 Subject: [PATCH] fix: test --- .../events_streaming/doctype/event_consumer/event_consumer.py | 2 +- .../events_streaming/doctype/event_producer/event_producer.py | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/frappe/events_streaming/doctype/event_consumer/event_consumer.py b/frappe/events_streaming/doctype/event_consumer/event_consumer.py index 38cdc40238..7596643f50 100644 --- a/frappe/events_streaming/doctype/event_consumer/event_consumer.py +++ b/frappe/events_streaming/doctype/event_consumer/event_consumer.py @@ -42,7 +42,7 @@ def register_consumer(event_consumer, subscribed_doctypes, user): # so that, updates after subscribing are consumed and not the old ones. last_update = get_last_update() - return json.dumps({'api_key': api_key, 'api_secret': api_secret, 'last_update': last_update}) + return {'api_key': api_key, 'api_secret': api_secret, 'last_update': last_update} def get_consumer_site(consumer_url): consumer_doc = frappe.get_doc('Event Consumer', consumer_url) diff --git a/frappe/events_streaming/doctype/event_producer/event_producer.py b/frappe/events_streaming/doctype/event_producer/event_producer.py index 0ec474d6fe..2dc7220a54 100644 --- a/frappe/events_streaming/doctype/event_producer/event_producer.py +++ b/frappe/events_streaming/doctype/event_producer/event_producer.py @@ -22,7 +22,7 @@ class EventProducer(Document): def create_event_consumer(self): '''register event consumer on the producer site''' - producer_site = FrappeClient(self.producer_url) + producer_site = FrappeClient(self.producer_url, verify=False) subscribed_doctypes = [] for entry in self.event_configuration: if entry.has_mapping: @@ -36,7 +36,6 @@ class EventProducer(Document): 'subscribed_doctypes': json.dumps(subscribed_doctypes), 'user': self.user }) - response = json.loads(response) self.api_key = response['api_key'] self.api_secret = response['api_secret'] self.last_update = response['last_update']