Changed PikaTransport._call_message_callback for readability

dan-fernandes · dan-fernandes · commit aa9a13f42c20 · 2022-11-24T09:39:11.000Z
diff --git a/src/workflows/transport/pika_transport.py b/src/workflows/transport/pika_transport.py
@@ -341,7 +341,9 @@ def _call_message_callback(
                 "subscription": subscription_id,
             }
         )
-        self.subscription_callback(subscription_id)(
+        target_function = self.subscription_callback(subscription_id)
+
+        target_function(
             merged_headers,
             body,
         )

Original file line number	Diff line number	Diff line change
`@@ -341,7 +341,9 @@ def _call_message_callback(`
`341`	`341`	`"subscription": subscription_id,`
`342`	`342`	`}`
`343`	`343`	`)`
`344`		`- self.subscription_callback(subscription_id)(`
	`344`	`+ target_function = self.subscription_callback(subscription_id)`
	`345`	`+`
	`346`	`+ target_function(`
`345`	`347`	`merged_headers,`
`346`	`348`	`body,`
`347`	`349`	`)`