Closed atompie closed 2 years ago
This is an error in scheduler plugin and requires rebuild of GRPC stubs. We need to extend payload with request data from event.
async def schedule(self, schedule_at, callback_host, source_id, profile_id, session_id, event_type, properties, context): # todo extend payload with request data from event message = pb2.Payload( time=schedule_at, callback_host=callback_host, source_id=source_id, profile_id=profile_id, session_id=session_id, event_type=event_type, properties=self._to_struct(properties), context=self._to_struct(context) )
Done in 0.7.2
Describe the bug
This is an error in scheduler plugin and requires rebuild of GRPC stubs. We need to extend payload with request data from event.