Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def insert_data(self, processed_data):
- db_session_commit(processed_data)
- def calculate_something(self, data):
- processed_data = external_lib_function(data)
- print(processed_data)
- async def wrapper(self, data):
- processed_data = self.calculate_something(data)
- self.insert_data(processed_data)
- async def main():
- if True:
- global nursery
- async with trio.open_nursery() as _nursery:
- nursery = _nursery
- await trio.to_thread.run_sync(self.wrapper, data)
- trio.run(main)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement