tuoheng_airport_stream_discard_20240715/common/Constant.py

# -*- coding: utf-8 -*-
from multiprocessing import Queue

SHARE_QUEUE = Queue()


def get_share_queue():
    return SHARE_QUEUE


TASK_RECORD = {
    "stream": None
}


def get_task_record():
    return TASK_RECORD