from django.db.models import query
from .celery_base import CeleryBaseService

__all__ = ['CeleryDefaultService']


class CeleryDefaultService(CeleryBaseService):

    def __init__(self,  **kwargs):
        queue = kwargs.pop('queue', 'celery')
        super().__init__(queue=queue, **kwargs)

    def start_other(self):
        from terminal.startup import CeleryTerminal
        celery_terminal = CeleryTerminal()
        celery_terminal.start_heartbeat_thread()

