projects
/
osm
/
RO.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Reformat files according to new black validation
[osm/RO.git]
/
NG-RO
/
osm_ng_ro
/
ns_thread.py
diff --git
a/NG-RO/osm_ng_ro/ns_thread.py
b/NG-RO/osm_ng_ro/ns_thread.py
index
6e9f104
..
be53027
100644
(file)
--- a/
NG-RO/osm_ng_ro/ns_thread.py
+++ b/
NG-RO/osm_ng_ro/ns_thread.py
@@
-27,9
+27,9
@@
A ro_task can contain several 'tasks', each one with a target, where to store th
from copy import deepcopy
from http import HTTPStatus
import logging
from copy import deepcopy
from http import HTTPStatus
import logging
-from os import mkdir
+from os import makedirs
+from os import path
import queue
import queue
-from shutil import rmtree
import threading
import time
import traceback
import threading
import time
import traceback
@@
-39,7
+39,8
@@
from unittest.mock import Mock
from importlib_metadata import entry_points
from osm_common.dbbase import DbException
from osm_ng_ro.vim_admin import LockRenew
from importlib_metadata import entry_points
from osm_common.dbbase import DbException
from osm_ng_ro.vim_admin import LockRenew
-from osm_ro_plugin import sdnconn, vimconn
+from osm_ro_plugin import sdnconn
+from osm_ro_plugin import vimconn
from osm_ro_plugin.sdn_dummy import SdnDummyConnector
from osm_ro_plugin.vim_dummy import VimDummyConnector
import yaml
from osm_ro_plugin.sdn_dummy import SdnDummyConnector
from osm_ro_plugin.vim_dummy import VimDummyConnector
import yaml
@@
-747,8
+748,10
@@
class VimInteractionFlavor(VimInteractionBase):
try:
flavor_data = task["find_params"]["flavor_data"]
vim_flavor_id = target_vim.get_flavor_id_from_data(flavor_data)
try:
flavor_data = task["find_params"]["flavor_data"]
vim_flavor_id = target_vim.get_flavor_id_from_data(flavor_data)
- except vimconn.VimConnNotFoundException:
- self.logger.warning("VimConnNotFoundException occured.")
+ except vimconn.VimConnNotFoundException as flavor_not_found_msg:
+ self.logger.warning(
+ f"VimConnNotFoundException occured: {flavor_not_found_msg}"
+ )
if not vim_flavor_id and task.get("params"):
# CREATE
if not vim_flavor_id and task.get("params"):
# CREATE
@@
-1037,7
+1040,6
@@
class VimInteractionSdnNet(VimInteractionBase):
return self.new(ro_task, task_create_index, None)
def new(self, ro_task, task_index, task_depends):
return self.new(ro_task, task_create_index, None)
def new(self, ro_task, task_index, task_depends):
-
task = ro_task["tasks"][task_index]
task_id = task["task_id"]
target_vim = self.my_vims[ro_task["target_id"]]
task = ro_task["tasks"][task_index]
task_id = task["task_id"]
target_vim = self.my_vims[ro_task["target_id"]]
@@
-1587,7
+1589,7
@@
class NsWorker(threading.Thread):
self.task_lock.release()
return False
self.task_lock.release()
return False
- def _process_vim_config(self, target_id
, db_vim)
:
+ def _process_vim_config(self, target_id
: str, db_vim: dict) -> None
:
"""
Process vim config, creating vim configuration files as ca_cert
:param target_id: vim/sdn/wim + id
"""
Process vim config, creating vim configuration files as ca_cert
:param target_id: vim/sdn/wim + id
@@
-1598,17
+1600,14
@@
class NsWorker(threading.Thread):
return
file_name = ""
return
file_name = ""
+ work_dir = "/app/osm_ro/certs"
try:
if db_vim["config"].get("ca_cert_content"):
try:
if db_vim["config"].get("ca_cert_content"):
- file_name =
"{}:{}".format(target_id, self.worker_index)
+ file_name =
f"{work_dir}/{target_id}:{self.worker_index}"
- try:
- mkdir(file_name)
- except FileExistsError:
- self.logger.exception(
- "FileExistsError occured while processing vim_config."
- )
+ if not path.isdir(file_name):
+ makedirs(file_name)
file_name = file_name + "/ca_cert"
file_name = file_name + "/ca_cert"
@@
-1659,10
+1658,6
@@
class NsWorker(threading.Thread):
self.vim_targets.remove(target_id)
self.logger.info("Unloaded {}".format(target_id))
self.vim_targets.remove(target_id)
self.logger.info("Unloaded {}".format(target_id))
- rmtree("{}:{}".format(target_id, self.worker_index))
- except FileNotFoundError:
- # This is raised by rmtree if folder does not exist.
- self.logger.exception("FileNotFoundError occured while unloading VIM.")
except Exception as e:
self.logger.error("Cannot unload {}: {}".format(target_id, e))
except Exception as e:
self.logger.error("Cannot unload {}: {}".format(target_id, e))
@@
-2419,7
+2414,10
@@
class NsWorker(threading.Thread):
)
if task["action"] == "DELETE":
)
if task["action"] == "DELETE":
- (new_status, db_vim_info_update,) = self._delete_task(
+ (
+ new_status,
+ db_vim_info_update,
+ ) = self._delete_task(
ro_task, task_index, task_depends, db_ro_task_update
)
new_status = (
ro_task, task_index, task_depends, db_ro_task_update
)
new_status = (
@@
-2467,7
+2465,10
@@
class NsWorker(threading.Thread):
else:
refresh_at = ro_task["vim_info"]["refresh_at"]
if refresh_at and refresh_at != -1 and now > refresh_at:
else:
refresh_at = ro_task["vim_info"]["refresh_at"]
if refresh_at and refresh_at != -1 and now > refresh_at:
- (new_status, db_vim_info_update,) = self.item2class[
+ (
+ new_status,
+ db_vim_info_update,
+ ) = self.item2class[
task["item"]
].refresh(ro_task)
_update_refresh(new_status)
task["item"]
].refresh(ro_task)
_update_refresh(new_status)