Skip to content

Commit

Permalink
restructure middleware directory
Browse files Browse the repository at this point in the history
  • Loading branch information
Ayush5120 committed Sep 30, 2023
1 parent db80e5e commit afc42ad
Show file tree
Hide file tree
Showing 2 changed files with 26 additions and 22 deletions.
23 changes: 1 addition & 22 deletions pro_tes/middleware/middleware.py
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
"""Middleware to inject into TES requests."""

import abc
from typing import List
import requests

from pro_tes.middleware_handler.abstract_middleware import AbstractMiddleware
from pro_tes.exceptions import (
NoTesInstancesAvailable,
TesUriError,
Expand All @@ -15,27 +15,6 @@
# pragma pylint: disable=too-few-public-methods


class AbstractMiddleware(metaclass=abc.ABCMeta):
"""Abstract class to implement different middleware."""

@abc.abstractmethod
def set_request(
self,
request: requests.Request,
*args,
**kwargs
) -> requests.Request:
"""Set the incoming request object.
Abstract method.
Args:
request: The incoming request object.
*args: Variable length argument list.
**kwargs: Arbitrary keyword arguments.
"""


class DistanceTaskDistribution(AbstractMiddleware):
"""Inject task distribution logic.
Expand Down
25 changes: 25 additions & 0 deletions pro_tes/middleware_handler/abstract_middleware.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
"""Parent Abstract Class for all the middlewares"""

import abc
import requests


class AbstractMiddleware(metaclass=abc.ABCMeta):
"""Abstract class to implement different middleware."""

@abc.abstractmethod
def set_request(
self,
request: requests.Request,
*args,
**kwargs
) -> requests.Request:
"""Set the incoming request object.
Abstract method.
Args:
request: The incoming request object.
*args: Variable length argument list.
**kwargs: Arbitrary keyword arguments.
"""

0 comments on commit afc42ad

Please sign in to comment.