# Path: virtool/dispatcher/operations.py
# INSERT: Operation = "insert"
# UPDATE: Operation = "update"
# DELETE: Operation = "delete"


import asyncio
import json
from asyncio import CancelledError
from typing import Sequence, Union
from aioredis import Redis
from virtool.dispatcher.operations import Operation




class DispatcherClient:
    def __init__(self, redis: Redis):
        self._redis = redis

# Path: virtool/dispatcher/operations.py
# INSERT: Operation = "insert"
# UPDATE: Operation = "update"
# DELETE: Operation = "delete"


# Path: virtool/dispatcher/client.py
import asyncio
import json
from asyncio import CancelledError
from typing import Sequence, Union
from aioredis import Redis
from virtool.dispatcher.operations import Operation





class DispatcherClient:
    def __init__(self, redis: Redis):
        self._redis = redis

        self._q = asyncio.Queue()