diff --git a/gso/main.py b/gso/main.py index e95976e5e202b1dea9a086450767e282e5650b9f..ca9268a0491b05f2fce7531466d2497c9adf3608 100644 --- a/gso/main.py +++ b/gso/main.py @@ -4,12 +4,13 @@ The main module, from where GSO is run. from orchestrator import OrchestratorCore from orchestrator.cli.main import app as core_cli from orchestrator.settings import AppSettings + # pylint: disable=unused-import import gso.products # noqa: F401 + # pylint: disable=unused-import import gso.workflows # noqa: F401 - app = OrchestratorCore(base_settings=AppSettings()) if __name__ == "__main__": diff --git a/gso/products/product_blocks/device.py b/gso/products/product_blocks/device.py index cc627b0e1509d6f3822e8ae398071fdee591ac92..0fd8f693ff4a37ccd55bbc2d2ffddc15dce8b787 100644 --- a/gso/products/product_blocks/device.py +++ b/gso/products/product_blocks/device.py @@ -1,10 +1,10 @@ +import ipaddress from typing import Optional from orchestrator.domain.base import ProductBlockModel from orchestrator.types import SubscriptionLifecycle, strEnum -from gso.products.product_blocks.site \ - import SiteBlock, SiteBlockInactive, SiteBlockProvisioning -import ipaddress + +from gso.products.product_blocks.site import SiteBlock, SiteBlockInactive, SiteBlockProvisioning class DeviceVendor(strEnum): diff --git a/gso/products/product_blocks/iptrunk.py b/gso/products/product_blocks/iptrunk.py index 629cf459853f86edb1cba53faf1f14ec409089d1..c74df8f7b0931ef43d2025bcecb62d3609d745c9 100644 --- a/gso/products/product_blocks/iptrunk.py +++ b/gso/products/product_blocks/iptrunk.py @@ -1,11 +1,11 @@ +import ipaddress from typing import Optional -from pydantic import Field from orchestrator.domain.base import ProductBlockModel from orchestrator.types import SubscriptionLifecycle, strEnum -from gso.products.product_blocks.device \ - import DeviceBlock, DeviceBlockInactive, DeviceBlockProvisioning -import ipaddress +from pydantic import Field + +from gso.products.product_blocks.device import DeviceBlock, DeviceBlockInactive, DeviceBlockProvisioning class IptrunkType(strEnum): diff --git a/gso/products/product_types/device.py b/gso/products/product_types/device.py index f2ecb3d94297f79ca73c0571d4a8a503d54d0502..2fa03627ffc5ba7578e555549757391256be6544 100644 --- a/gso/products/product_types/device.py +++ b/gso/products/product_types/device.py @@ -1,8 +1,7 @@ from orchestrator.domain.base import SubscriptionModel from orchestrator.types import SubscriptionLifecycle, strEnum -from gso.products.product_blocks.device \ - import DeviceBlock, DeviceBlockInactive, DeviceBlockProvisioning +from gso.products.product_blocks.device import DeviceBlock, DeviceBlockInactive, DeviceBlockProvisioning class DeviceType(strEnum): diff --git a/gso/products/product_types/iptrunk.py b/gso/products/product_types/iptrunk.py index d12e010850cedc8d1f98fd2d38c33d4972b8fd50..6f0b40404dce5c1ad5733ee034a33ffe10604bfb 100644 --- a/gso/products/product_types/iptrunk.py +++ b/gso/products/product_types/iptrunk.py @@ -1,8 +1,7 @@ from orchestrator.domain.base import SubscriptionModel from orchestrator.types import SubscriptionLifecycle -from gso.products.product_blocks.iptrunk \ - import IptrunkBlock, IptrunkBlockInactive, IptrunkBlockProvisioning +from gso.products.product_blocks.iptrunk import IptrunkBlock, IptrunkBlockInactive, IptrunkBlockProvisioning class IptrunkInactive(SubscriptionModel, is_base=True): diff --git a/gso/products/product_types/site.py b/gso/products/product_types/site.py index 8c3379c917812600e875243938645010a386ea42..7571acc42ea001b349bf7516f55a295ea20d06ed 100644 --- a/gso/products/product_types/site.py +++ b/gso/products/product_types/site.py @@ -1,8 +1,7 @@ from orchestrator.domain.base import SubscriptionModel from orchestrator.types import SubscriptionLifecycle -from gso.products.product_blocks.site \ - import SiteBlock, SiteBlockInactive, SiteBlockProvisioning +from gso.products.product_blocks.site import SiteBlock, SiteBlockInactive, SiteBlockProvisioning class SiteInactive(SubscriptionModel, is_base=True): diff --git a/gso/services/_ipam.py b/gso/services/_ipam.py index dc7df6837e91175f5cff54d4d94d48040bb215a7..89dd186eb82dd40851d47913e6dc033f09f16f34 100644 --- a/gso/services/_ipam.py +++ b/gso/services/_ipam.py @@ -1,9 +1,10 @@ import ipaddress -import requests from enum import Enum +from typing import Union + +import requests from pydantic import BaseSettings from requests.auth import HTTPBasicAuth -from typing import Union from gso import settings diff --git a/gso/services/ipam.py b/gso/services/ipam.py index 724db9019076031eda23e9bc4faa5de950531d3a..c438ed7c919a8f35d8e7f47692fca30b7aa89349 100644 --- a/gso/services/ipam.py +++ b/gso/services/ipam.py @@ -1,7 +1,8 @@ import ipaddress -from pydantic import BaseSettings from typing import Union +from pydantic import BaseSettings + from gso.services import _ipam diff --git a/gso/services/provisioning_proxy.py b/gso/services/provisioning_proxy.py index 0c4dbb1c54dea0ece719eccdc612c9f6e61fa020..2fe01ffcf0476184fadf73dbe7feae0f4c2b1108 100644 --- a/gso/services/provisioning_proxy.py +++ b/gso/services/provisioning_proxy.py @@ -9,16 +9,17 @@ import requests from orchestrator import inputstep from orchestrator.config.assignee import Assignee from orchestrator.domain import SubscriptionModel + # noinspection PyProtectedMember from orchestrator.forms import FormPage, ReadOnlyField from orchestrator.forms.validators import Accept, Label, LongText -from orchestrator.types import UUIDstr, State, strEnum +from orchestrator.types import State, UUIDstr, strEnum from orchestrator.utils.json import json_dumps from pydantic import validator from gso import settings from gso.products.product_types.device import DeviceProvisioning -from gso.products.product_types.iptrunk import IptrunkProvisioning, Iptrunk +from gso.products.product_types.iptrunk import Iptrunk, IptrunkProvisioning logger = logging.getLogger(__name__) diff --git a/gso/services/resource_manager.py b/gso/services/resource_manager.py index 334e7b3e93b5093152014278a75169cd549a68b9..13106d8a91a7c96e73ac6309c1557f9f4b005c74 100644 --- a/gso/services/resource_manager.py +++ b/gso/services/resource_manager.py @@ -1,6 +1,7 @@ -from gso import settings import requests +from gso import settings + def import_new_router(router_name, oss_params=settings.OSSParams): r = requests.post( diff --git a/gso/settings.py b/gso/settings.py index a28b4eae0e033d463e41aff59ddd150222dfff0d..dd81fe6460030fcf0c64cda4c6eec10ba386757f 100644 --- a/gso/settings.py +++ b/gso/settings.py @@ -4,6 +4,7 @@ GSO settings, ensuring that the required parameters are set correctly. import ipaddress import json import os + # from pydantic import BaseSettings, Field from pydantic import BaseSettings diff --git a/gso/workflows/device/create_device.py b/gso/workflows/device/create_device.py index 681b52590d88d856b4d64373b53332c9191e43ed..dba6510dd4ab4bb9b97c65321bdab5409a83fd3f 100644 --- a/gso/workflows/device/create_device.py +++ b/gso/workflows/device/create_device.py @@ -8,26 +8,17 @@ from orchestrator.db.models import ProductTable, SubscriptionTable from orchestrator.forms import FormPage from orchestrator.forms.validators import Choice from orchestrator.targets import Target -from orchestrator.types import FormGenerator, State -from orchestrator.types import SubscriptionLifecycle, UUIDstr +from orchestrator.types import FormGenerator, State, SubscriptionLifecycle, UUIDstr from orchestrator.workflow import done, init, step, workflow -from orchestrator.workflows.steps import resync, set_status -from orchestrator.workflows.steps import store_process_subscription +from orchestrator.workflows.steps import resync, set_status, store_process_subscription from orchestrator.workflows.utils import wrap_create_initial_input_form from gso.products.product_blocks import device as device_pb from gso.products.product_types import device -from gso.products.product_types.device import ( - DeviceInactive, - DeviceProvisioning, -) +from gso.products.product_types.device import DeviceInactive, DeviceProvisioning from gso.products.product_types.site import Site -from gso.services import _ipam -from gso.services import provisioning_proxy -from gso.services.provisioning_proxy import ( - await_pp_results, - confirm_pp_results, -) +from gso.services import _ipam, provisioning_proxy +from gso.services.provisioning_proxy import await_pp_results, confirm_pp_results def site_selector() -> Choice: diff --git a/gso/workflows/device/terminate_device.py b/gso/workflows/device/terminate_device.py index c8b9147372fbb76b8433393fd5fc0066e4fc72b4..cd56cd1477dfce1a719afcf8657e4619855cbf2b 100644 --- a/gso/workflows/device/terminate_device.py +++ b/gso/workflows/device/terminate_device.py @@ -1,19 +1,15 @@ import ipaddress + from orchestrator.forms import FormPage from orchestrator.forms.validators import Label from orchestrator.targets import Target from orchestrator.types import InputForm, SubscriptionLifecycle, UUIDstr from orchestrator.workflow import done, init, step, workflow -from gso.services import ipam -from orchestrator.workflows.steps import ( - resync, - set_status, - store_process_subscription, - unsync, -) +from orchestrator.workflows.steps import resync, set_status, store_process_subscription, unsync from orchestrator.workflows.utils import wrap_modify_initial_input_form from gso.products.product_types.device import Device +from gso.services import ipam def initial_input_form_generator(subscription_id: UUIDstr) -> InputForm: diff --git a/gso/workflows/iptrunk/create_iptrunk.py b/gso/workflows/iptrunk/create_iptrunk.py index 5c5f9febfa452731a80a8f7a7582856aca6a61dd..127caf0ade9912dcceb5c0da54e31d7bd20cb11c 100644 --- a/gso/workflows/iptrunk/create_iptrunk.py +++ b/gso/workflows/iptrunk/create_iptrunk.py @@ -6,25 +6,17 @@ from orchestrator.db.models import ProductTable, SubscriptionTable from orchestrator.forms import FormPage from orchestrator.forms.validators import Choice, UniqueConstrainedList from orchestrator.targets import Target -from orchestrator.types import FormGenerator, State -from orchestrator.types import SubscriptionLifecycle, UUIDstr +from orchestrator.types import FormGenerator, State, SubscriptionLifecycle, UUIDstr from orchestrator.workflow import done, init, step, workflow -from orchestrator.workflows.steps import resync, set_status -from orchestrator.workflows.steps import store_process_subscription +from orchestrator.workflows.steps import resync, set_status, store_process_subscription from orchestrator.workflows.utils import wrap_create_initial_input_form from gso.products.product_blocks import PhyPortCapacity from gso.products.product_blocks.iptrunk import IptrunkType from gso.products.product_types.device import Device -from gso.products.product_types.iptrunk import ( - IptrunkInactive, - IptrunkProvisioning, -) -from gso.services import provisioning_proxy, _ipam -from gso.services.provisioning_proxy import ( - confirm_pp_results, - await_pp_results, -) +from gso.products.product_types.iptrunk import IptrunkInactive, IptrunkProvisioning +from gso.services import _ipam, provisioning_proxy +from gso.services.provisioning_proxy import await_pp_results, confirm_pp_results def initial_input_form_generator(product_name: str) -> FormGenerator: diff --git a/gso/workflows/iptrunk/modify_generic.py b/gso/workflows/iptrunk/modify_generic.py index 9c3c633c352be9c555ca6afa39d92b58bb3ffcfe..c4745e1f8c401e7d7e5b4ddc2d07de311db97274 100644 --- a/gso/workflows/iptrunk/modify_generic.py +++ b/gso/workflows/iptrunk/modify_generic.py @@ -1,24 +1,18 @@ import ipaddress + from orchestrator.forms import FormPage, ReadOnlyField +from orchestrator.forms.validators import Choice, UniqueConstrainedList from orchestrator.targets import Target -from orchestrator.types import FormGenerator, State -from orchestrator.types import UUIDstr +from orchestrator.types import FormGenerator, State, UUIDstr from orchestrator.workflow import done, init, step, workflow -from orchestrator.workflows.steps import resync -from orchestrator.workflows.steps import store_process_subscription, unsync +from orchestrator.workflows.steps import resync, store_process_subscription, unsync from orchestrator.workflows.utils import wrap_modify_initial_input_form -from orchestrator.forms.validators import Choice, UniqueConstrainedList -from gso.products.product_blocks.iptrunk import IptrunkType -from gso.products.product_blocks import PhyPortCapacity -from gso.products.product_types.iptrunk import ( - Iptrunk, -) +from gso.products.product_blocks import PhyPortCapacity +from gso.products.product_blocks.iptrunk import IptrunkType +from gso.products.product_types.iptrunk import Iptrunk from gso.services import provisioning_proxy -from gso.services.provisioning_proxy import ( - confirm_pp_results, - await_pp_results, -) +from gso.services.provisioning_proxy import await_pp_results, confirm_pp_results def initial_input_form_generator(subscription_id: UUIDstr) -> FormGenerator: diff --git a/gso/workflows/iptrunk/modify_isis_metric.py b/gso/workflows/iptrunk/modify_isis_metric.py index 8d769b604b8c96cb3c33c7fe76087af21a2d636c..e8911c76d2f96351a0dc7b912f09eabd5b65fb28 100644 --- a/gso/workflows/iptrunk/modify_isis_metric.py +++ b/gso/workflows/iptrunk/modify_isis_metric.py @@ -1,20 +1,13 @@ from orchestrator.forms import FormPage from orchestrator.targets import Target -from orchestrator.types import FormGenerator, State -from orchestrator.types import UUIDstr +from orchestrator.types import FormGenerator, State, UUIDstr from orchestrator.workflow import done, init, step, workflow -from orchestrator.workflows.steps import resync -from orchestrator.workflows.steps import store_process_subscription, unsync +from orchestrator.workflows.steps import resync, store_process_subscription, unsync from orchestrator.workflows.utils import wrap_modify_initial_input_form -from gso.products.product_types.iptrunk import ( - Iptrunk, -) +from gso.products.product_types.iptrunk import Iptrunk from gso.services import provisioning_proxy -from gso.services.provisioning_proxy import ( - confirm_pp_results, - await_pp_results, -) +from gso.services.provisioning_proxy import await_pp_results, confirm_pp_results def initial_input_form_generator(subscription_id: UUIDstr) -> FormGenerator: diff --git a/gso/workflows/iptrunk/terminate_iptrunk.py b/gso/workflows/iptrunk/terminate_iptrunk.py index 4190ee4deb7db227f9a0d307a9c024bc2e447411..ba1b9aa03ac9f3e46a7a6c970e2b6758394cef94 100644 --- a/gso/workflows/iptrunk/terminate_iptrunk.py +++ b/gso/workflows/iptrunk/terminate_iptrunk.py @@ -1,25 +1,17 @@ # noinspection PyProtectedMember import ipaddress + from orchestrator.forms import FormPage from orchestrator.forms.validators import Label from orchestrator.targets import Target -from orchestrator.types import InputForm, SubscriptionLifecycle, UUIDstr -from orchestrator.types import State +from orchestrator.types import InputForm, State, SubscriptionLifecycle, UUIDstr from orchestrator.workflow import done, init, step, workflow -from orchestrator.workflows.steps import ( - resync, - set_status, - store_process_subscription, - unsync, -) +from orchestrator.workflows.steps import resync, set_status, store_process_subscription, unsync from orchestrator.workflows.utils import wrap_modify_initial_input_form from gso.products.product_types.iptrunk import Iptrunk -from gso.services import provisioning_proxy, ipam -from gso.services.provisioning_proxy import ( - confirm_pp_results, - await_pp_results, -) +from gso.services import ipam, provisioning_proxy +from gso.services.provisioning_proxy import await_pp_results, confirm_pp_results def initial_input_form_generator(subscription_id: UUIDstr) -> InputForm: diff --git a/gso/workflows/site/create_site.py b/gso/workflows/site/create_site.py index 0773d71c3ccdea5103211dabd94358d73201658b..756c992a519e349b088abe2642efd2f616ae3b3f 100644 --- a/gso/workflows/site/create_site.py +++ b/gso/workflows/site/create_site.py @@ -2,11 +2,9 @@ from uuid import uuid4 from orchestrator.forms import FormPage from orchestrator.targets import Target -from orchestrator.types import FormGenerator, State -from orchestrator.types import SubscriptionLifecycle, UUIDstr +from orchestrator.types import FormGenerator, State, SubscriptionLifecycle, UUIDstr from orchestrator.workflow import done, init, step, workflow -from orchestrator.workflows.steps import resync, set_status -from orchestrator.workflows.steps import store_process_subscription +from orchestrator.workflows.steps import resync, set_status, store_process_subscription from orchestrator.workflows.utils import wrap_create_initial_input_form from gso.products.product_blocks import site as site_pb diff --git a/setup.py b/setup.py index 333091fe42794a4d8d2118c0761dd53864872e3c..5dbfaf3364045bdbc9ea7c5b0ca84da3ebad47a2 100644 --- a/setup.py +++ b/setup.py @@ -1,4 +1,4 @@ -from setuptools import setup, find_packages +from setuptools import find_packages, setup setup( name='geant-service-orchestrator', diff --git a/test/test_ipam.py b/test/test_ipam.py index e3191bcc3daf920beceaed175d9884f7b553ba7d..ef1e7111a90913525a3393128a33992aacf7a8cc 100644 --- a/test/test_ipam.py +++ b/test/test_ipam.py @@ -1,7 +1,7 @@ import ipaddress -import pytest import re +import pytest import responses from gso.services import ipam