From 5361467f9d4db132097479ea6fca6045f4f5f8ea Mon Sep 17 00:00:00 2001 From: Rucha Mahabal Date: Mon, 9 Dec 2019 18:02:54 +0530 Subject: [PATCH] fix: incoming_change boolean field for postgres --- .../events_streaming/doctype/event_consumer/event_consumer.py | 2 +- .../events_streaming/doctype/event_producer/event_producer.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/frappe/events_streaming/doctype/event_consumer/event_consumer.py b/frappe/events_streaming/doctype/event_consumer/event_consumer.py index e6fe470697..61d32f19f3 100644 --- a/frappe/events_streaming/doctype/event_consumer/event_consumer.py +++ b/frappe/events_streaming/doctype/event_consumer/event_consumer.py @@ -23,7 +23,7 @@ class EventConsumer(Document): if not self.incoming_change: self.update_consumer_status() else: - frappe.db.set_value(self.doctype, self.name, 'incoming_change', False) + frappe.db.set_value(self.doctype, self.name, 'incoming_change', 0) def update_consumer_status(self): consumer_site = get_consumer_site(self.callback_url) diff --git a/frappe/events_streaming/doctype/event_producer/event_producer.py b/frappe/events_streaming/doctype/event_producer/event_producer.py index 2e672318cb..9546aae384 100644 --- a/frappe/events_streaming/doctype/event_producer/event_producer.py +++ b/frappe/events_streaming/doctype/event_producer/event_producer.py @@ -30,7 +30,7 @@ class EventProducer(Document): self.create_custom_fields() else: #when producer doc is updated it updates the consumer doc, set flag to avoid deadlock - frappe.db.set_value(self.doctype, self.name, 'incoming_change', False) + frappe.db.set_value(self.doctype, self.name, 'incoming_change', 0) def create_event_consumer(self): '''register event consumer on the producer site'''