def check_celery_version(*args, **kwargs): if LooseVersion(__version__) < LooseVersion('4.0.0'): sys.exit("""You are running Celery {}. girder-worker requires celery>=4.0.0""".format(__version__))