Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 1 addition & 2 deletions wavefront/server/apps/floware/floware/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
from common_module.log.logger import logger
from common_module.prometheus.prometheus_middleware import PrometheusMiddleware
from common_module.response_formatter import ResponseFormatter
from db_repo_module.cache.azure_redis_auth import patch_redis_for_azure

from db_repo_module.database.connection import DatabaseClient
from db_repo_module.db_repo_container import DatabaseModuleContainer
from fastapi import HTTPException
Expand Down Expand Up @@ -236,7 +236,6 @@

@asynccontextmanager
async def lifespan(app: FastAPI):
patch_redis_for_azure()
# Startup code (runs before the application starts)
logger.info('Starting application...')

Expand Down
Original file line number Diff line number Diff line change
@@ -1,20 +1,12 @@
from celery import Celery
from celery.signals import (
worker_process_init,
worker_process_shutdown,
worker_shutdown,
)

from celery_worker.env import CELERY_BROKER_URL, CELERY_RESULT_BACKEND


@worker_process_init.connect
def setup_azure_redis_auth(**kwargs):
from db_repo_module.cache.azure_redis_auth import patch_redis_for_azure

patch_redis_for_azure()


def teardown_event_loop(**kwargs):
from celery_worker.worker_setup import close_event_loop

Expand Down

This file was deleted.

Loading