ebram96

from celery import current_app


class CeleryHelper:
    """Contains helper functionalities to be used while interacting with Celery."""
    @staticmethod
    def is_being_executed(task_name: str) -> bool:
        """Returns whether the task with given task_name is already being executed.
        
        Args: