Commit 9ac8eee1 authored by Pelayo Torres's avatar Pelayo Torres
Browse files

Removed duplicated and unused imports

parent 84c4ca4d
Loading
Loading
Loading
Loading
Loading
+4 −5
Original line number Original line Diff line number Diff line
@@ -6,6 +6,9 @@ from datetime import datetime
from logging.handlers import RotatingFileHandler
from logging.handlers import RotatingFileHandler


import connexion
import connexion
import encoder
from config import Config
from core.consumer_messager import Subscriber
from flask_apscheduler import APScheduler
from flask_apscheduler import APScheduler
from flask_executor import Executor
from flask_executor import Executor
from flask_jwt_extended import JWTManager
from flask_jwt_extended import JWTManager
@@ -19,10 +22,6 @@ from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.trace.export import BatchSpanProcessor
from opentelemetry.sdk.trace.export import BatchSpanProcessor
from opentelemetry.trace.propagation.tracecontext import TraceContextTextMapPropagator
from opentelemetry.trace.propagation.tracecontext import TraceContextTextMapPropagator


import encoder
from config import Config
from core.consumer_messager import Subscriber

NAME = "Invoker-Service"
NAME = "Invoker-Service"


# Setting log level
# Setting log level
@@ -36,7 +35,7 @@ def configure_monitoring(app, config):
    fluent_bit_host = config['monitoring']['fluent_bit_host']
    fluent_bit_host = config['monitoring']['fluent_bit_host']
    fluent_bit_port = config['monitoring']['fluent_bit_port']
    fluent_bit_port = config['monitoring']['fluent_bit_port']
    fluent_bit_sender = sender.FluentSender('Invoker-Service', host=fluent_bit_host, port=fluent_bit_port)
    fluent_bit_sender = sender.FluentSender('Invoker-Service', host=fluent_bit_host, port=fluent_bit_port)
    propagator = TraceContextTextMapPropagator()
    TraceContextTextMapPropagator()


    tracer_provider = TracerProvider(resource=resource)
    tracer_provider = TracerProvider(resource=resource)
    trace.set_tracer_provider(tracer_provider)
    trace.set_tracer_provider(tracer_provider)
+2 −2
Original line number Original line Diff line number Diff line
@@ -2,8 +2,8 @@ from functools import wraps


from cryptography import x509
from cryptography import x509
from cryptography.hazmat.backends import default_backend
from cryptography.hazmat.backends import default_backend
from flask import request, current_app
from flask import current_app, request
from flask_jwt_extended import jwt_required, get_jwt_identity
from flask_jwt_extended import get_jwt_identity, jwt_required


from ..core.apiinvokerenrolmentdetails import InvokerManagementOperations
from ..core.apiinvokerenrolmentdetails import InvokerManagementOperations
from ..core.validate_user import ControlAccess
from ..core.validate_user import ControlAccess
+2 −1
Original line number Original line Diff line number Diff line
from api_invoker_management.models.api_invoker_enrolment_details_patch import APIInvokerEnrolmentDetailsPatch  # noqa: E501
from api_invoker_management.models.api_invoker_enrolment_details_patch import \
    APIInvokerEnrolmentDetailsPatch  # noqa: E501




def modify_ind_api_invoke_enrolment(onboarding_id, body):  # noqa: E501
def modify_ind_api_invoke_enrolment(onboarding_id, body):  # noqa: E501
+5 −7
Original line number Original line Diff line number Diff line
@@ -5,21 +5,19 @@ from datetime import datetime


import requests
import requests
import rfc3987
import rfc3987
from api_invoker_management.db.db import MongoDatabse
from api_invoker_management.models.api_invoker_enrolment_details import APIInvokerEnrolmentDetails
from api_invoker_management.models.api_invoker_enrolment_details import APIInvokerEnrolmentDetails
from flask import current_app, Response
from flask import Response, current_app
from pymongo import ReturnDocument
from pymongo import ReturnDocument


from ..config import Config
from ..util import dict_to_camel_case, serialize_clean_camel_case
from .auth_manager import AuthManager
from .auth_manager import AuthManager
from .publisher import Publisher
from .publisher import Publisher
from .redis_event import RedisEvent
from .redis_event import RedisEvent
from .redis_internal_event import RedisInternalEvent
from .redis_internal_event import RedisInternalEvent
from .resources import Resource
from .resources import Resource
from .responses import bad_request_error, not_found_error, forbidden_error, internal_server_error, make_response
from .responses import bad_request_error, forbidden_error, internal_server_error, make_response, not_found_error
from ..config import Config
from ..util import dict_to_camel_case, serialize_clean_camel_case

from api_invoker_management.db.db import MongoDatabse



publisher_ops = Publisher()
publisher_ops = Publisher()


+1 −0
Original line number Original line Diff line number Diff line
import redis
import redis



class Publisher():
class Publisher():


    def __init__(self):
    def __init__(self):
Loading