this repo has no description
load additional plugs on manager startup (#2537)
* load additional plugs on manager startup
* cleanup
authored by
Aakash Singh
and committed by
GitHub
02c90560
a7fb6ea9
+13
-15
-15
install_plugins.py
-15
install_plugins.py
···
1
-
import json
2
-
import logging
3
-
import os
4
-
5
1
from plug_config import manager
6
-
from plugs.plug import Plug
7
-
8
-
logger = logging.getLogger(__name__)
9
-
10
-
11
-
if ADDITIONAL_PLUGS := os.getenv("ADDITIONAL_PLUGS"):
12
-
try:
13
-
for plug in json.loads(ADDITIONAL_PLUGS):
14
-
manager.add_plug(Plug(**plug))
15
-
except json.JSONDecodeError:
16
-
logger.error("ADDITIONAL_PLUGS is not a valid JSON")
17
2
18
3
manager.install()
+13
plugs/manager.py
+13
plugs/manager.py
···
1
+
import json
2
+
import logging
3
+
import os
1
4
import subprocess
2
5
import sys
3
6
from collections import defaultdict
4
7
5
8
from plugs.plug import Plug
6
9
10
+
logger = logging.getLogger(__name__)
11
+
7
12
8
13
class PlugManager:
9
14
"""
···
12
17
13
18
def __init__(self, plugs: list[Plug]):
14
19
self.plugs: list[Plug] = plugs
20
+
21
+
# load additional plugs from environment variable
22
+
if additional_plugs := os.getenv("ADDITIONAL_PLUGS"):
23
+
try:
24
+
for plug in json.loads(additional_plugs):
25
+
self.add_plug(Plug(**plug))
26
+
except json.JSONDecodeError:
27
+
logger.error("ADDITIONAL_PLUGS is not a valid JSON")
15
28
16
29
def install(self) -> None:
17
30
packages: list[str] = [f"{x.package_name}{x.version}" for x in self.plugs]