wip
This commit is contained in:
parent
80913481b9
commit
0026ec6256
@ -1,6 +1,6 @@
|
||||
import subprocess
|
||||
|
||||
from ..config import config
|
||||
from ..config import app_config as config
|
||||
from threading import Lock
|
||||
from typing import Union, List
|
||||
|
||||
|
@ -7,7 +7,6 @@ from .config import (
|
||||
setup_logging,
|
||||
app_config
|
||||
)
|
||||
from .validators import validate
|
||||
from ._configs import (
|
||||
LinuxBoardsConfig,
|
||||
ServicesListConfig
|
||||
|
@ -9,7 +9,6 @@ from typing import Optional, Any, MutableMapping, Union
|
||||
from argparse import ArgumentParser
|
||||
from enum import Enum, auto
|
||||
from os.path import join, isdir, isfile
|
||||
from . import validators
|
||||
from ..util import parse_addr
|
||||
|
||||
|
||||
@ -19,21 +18,6 @@ class RootSchemaType(Enum):
|
||||
LIST = auto()
|
||||
|
||||
|
||||
_my_validators = {}
|
||||
|
||||
|
||||
def _get_validator(name: str) -> Optional[callable]:
|
||||
if hasattr(validators, f'{name}_validator'):
|
||||
return getattr(validators, f'{name}_validator')
|
||||
if name in _my_validators:
|
||||
return _my_validators[name]
|
||||
return None
|
||||
|
||||
|
||||
def add_validator(name: str, f: callable):
|
||||
_my_validators[name] = f
|
||||
|
||||
|
||||
class ConfigUnit:
|
||||
NAME = 'dumb'
|
||||
|
||||
|
@ -1,7 +1,7 @@
|
||||
import logging
|
||||
|
||||
from zoneinfo import ZoneInfo
|
||||
from datetime import datetime, timedelta
|
||||
from datetime import datetime
|
||||
from clickhouse_driver import Client as ClickhouseClient
|
||||
from ..config import is_development_mode
|
||||
|
||||
|
@ -13,7 +13,7 @@ if __name__ == '__main__':
|
||||
mode = arg.mode[0]
|
||||
|
||||
mqtt = MqttWrapper(client_id=f'inverter_mqtt_{mode}',
|
||||
clean_session=arg.mode[0] != 'receiver')
|
||||
clean_session=mode != 'receiver')
|
||||
node = MqttNode(node_id='inverter')
|
||||
module_kwargs = {}
|
||||
if mode == 'sender':
|
||||
|
Loading…
x
Reference in New Issue
Block a user