refactor: increase buffer limit for TasksBuffer to 1000
This commit is contained in:
30
test.py
30
test.py
@@ -1,30 +0,0 @@
|
||||
import asyncio
|
||||
from idlelib.pyparse import trans
|
||||
from pydoc import browse
|
||||
|
||||
import background.tasks
|
||||
from background import taskiq_broker
|
||||
|
||||
|
||||
async def main():
|
||||
# # generate random json dict with strings and integers
|
||||
# def generate_json():
|
||||
# import random
|
||||
# import string
|
||||
# import json
|
||||
# data = {}
|
||||
# for i in range(0, 10):
|
||||
# key = ''.join(random.choices(string.ascii_lowercase, k=5))
|
||||
# value = random.randint(0, 100)
|
||||
# data[key] = value
|
||||
# return json.dumps(data)
|
||||
# # generate json dict
|
||||
# data = generate_json()
|
||||
await taskiq_broker.startup()
|
||||
await background.tasks.update_marketplace.kiq(41)
|
||||
await taskiq_broker.shutdown()
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
loop = asyncio.get_event_loop()
|
||||
loop.run_until_complete(main())
|
||||
Reference in New Issue
Block a user