These functions were not deferreds!
This commit is contained in:
@@ -43,7 +43,7 @@ class SendToDeviceRestServlet(servlet.RestServlet):
|
||||
self.txns = HttpTransactionCache(hs)
|
||||
self.device_message_handler = hs.get_device_message_handler()
|
||||
|
||||
@tracerutils.trace_defered_function_using_operation_name("sendToDevice")
|
||||
@tracerutils.trace_function_using_operation_name("sendToDevice")
|
||||
def on_PUT(self, request, message_type, txn_id):
|
||||
tracerutils.set_tag("message_type", message_type)
|
||||
tracerutils.set_tag("txn_id", txn_id)
|
||||
|
||||
@@ -127,7 +127,7 @@ class DeviceInboxWorkerStore(SQLBaseStore):
|
||||
|
||||
defer.returnValue(count)
|
||||
|
||||
@tracerutils.trace_defered_function
|
||||
@tracerutils.trace_function
|
||||
def get_new_device_msgs_for_remote(
|
||||
self, destination, last_stream_id, current_stream_id, limit
|
||||
):
|
||||
|
||||
Reference in New Issue
Block a user