You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2023/04/04 09:13:10 UTC
[iotdb] branch mlnode/test updated: apply isort & flake8
This is an automated email from the ASF dual-hosted git repository.
hui pushed a commit to branch mlnode/test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/mlnode/test by this push:
new d009085af2 apply isort & flake8
d009085af2 is described below
commit d009085af2114a6cd69b5e931773353956055aa9
Author: Minghui Liu <li...@foxmail.com>
AuthorDate: Tue Apr 4 17:12:49 2023 +0800
apply isort & flake8
---
mlnode/iotdb/mlnode/algorithm/factory.py | 4 ++--
mlnode/iotdb/mlnode/algorithm/metric.py | 1 +
mlnode/iotdb/mlnode/client.py | 5 ++---
mlnode/iotdb/mlnode/data_access/factory.py | 4 +++-
mlnode/iotdb/mlnode/data_access/offline/dataset.py | 5 +++--
mlnode/iotdb/mlnode/data_access/offline/source.py | 1 -
mlnode/iotdb/mlnode/parser.py | 5 ++---
mlnode/iotdb/mlnode/storage.py | 3 ++-
8 files changed, 15 insertions(+), 13 deletions(-)
diff --git a/mlnode/iotdb/mlnode/algorithm/factory.py b/mlnode/iotdb/mlnode/algorithm/factory.py
index c8771139d0..ed39e4e2b8 100644
--- a/mlnode/iotdb/mlnode/algorithm/factory.py
+++ b/mlnode/iotdb/mlnode/algorithm/factory.py
@@ -15,10 +15,10 @@
# specific language governing permissions and limitations
# under the License.
#
-import torch.nn as nn
-
from typing import Dict, Tuple
+import torch.nn as nn
+
from iotdb.mlnode.algorithm.enums import ForecastModelType, ForecastTaskType
from iotdb.mlnode.algorithm.models.forecast.dlinear import (dlinear,
dlinear_individual)
diff --git a/mlnode/iotdb/mlnode/algorithm/metric.py b/mlnode/iotdb/mlnode/algorithm/metric.py
index 562ffe04b1..1835b77721 100644
--- a/mlnode/iotdb/mlnode/algorithm/metric.py
+++ b/mlnode/iotdb/mlnode/algorithm/metric.py
@@ -17,6 +17,7 @@
#
from abc import abstractmethod
from typing import Dict
+
import numpy as np
all_metrics = ['RSE', 'CORR', 'MAE', 'MSE', 'RMSE', 'MAPE', 'MSPE']
diff --git a/mlnode/iotdb/mlnode/client.py b/mlnode/iotdb/mlnode/client.py
index d39156e0fd..3157006e57 100644
--- a/mlnode/iotdb/mlnode/client.py
+++ b/mlnode/iotdb/mlnode/client.py
@@ -16,14 +16,14 @@
# under the License.
#
import time
-from typing import List, Dict
+from typing import Dict, List
import pandas as pd
-from iotdb.mlnode import serde
from thrift.protocol import TBinaryProtocol, TCompactProtocol
from thrift.Thrift import TException
from thrift.transport import TSocket, TTransport
+from iotdb.mlnode import serde
from iotdb.mlnode.config import descriptor
from iotdb.mlnode.constant import TSStatusCode
from iotdb.mlnode.log import logger
@@ -34,7 +34,6 @@ from iotdb.thrift.confignode.ttypes import (TUpdateModelInfoReq,
TUpdateModelStateReq)
from iotdb.thrift.datanode import IMLNodeInternalRPCService
from iotdb.thrift.datanode.ttypes import (TFetchTimeseriesReq,
- TFetchTimeseriesResp,
TRecordModelMetricsReq)
from iotdb.thrift.mlnode import IMLNodeRPCService
from iotdb.thrift.mlnode.ttypes import TCreateTrainingTaskReq, TDeleteModelReq
diff --git a/mlnode/iotdb/mlnode/data_access/factory.py b/mlnode/iotdb/mlnode/data_access/factory.py
index 4c62ae3850..3c4c1a4b9b 100644
--- a/mlnode/iotdb/mlnode/data_access/factory.py
+++ b/mlnode/iotdb/mlnode/data_access/factory.py
@@ -15,8 +15,10 @@
# specific language governing permissions and limitations
# under the License.
#
-from torch.utils.data import Dataset
from typing import Dict, Tuple
+
+from torch.utils.data import Dataset
+
from iotdb.mlnode.data_access.enums import DatasetType, DataSourceType
from iotdb.mlnode.data_access.offline.dataset import (TimeSeriesDataset,
WindowDataset)
diff --git a/mlnode/iotdb/mlnode/data_access/offline/dataset.py b/mlnode/iotdb/mlnode/data_access/offline/dataset.py
index 3c42e9228b..a1b11ccd86 100644
--- a/mlnode/iotdb/mlnode/data_access/offline/dataset.py
+++ b/mlnode/iotdb/mlnode/data_access/offline/dataset.py
@@ -15,10 +15,11 @@
# specific language governing permissions and limitations
# under the License.
#
-import numpy as np
+from typing import Tuple
+import numpy as np
from torch.utils.data import Dataset
-from typing import Tuple
+
from iotdb.mlnode.data_access.offline.source import DataSource
from iotdb.mlnode.data_access.utils.timefeatures import time_features
diff --git a/mlnode/iotdb/mlnode/data_access/offline/source.py b/mlnode/iotdb/mlnode/data_access/offline/source.py
index c1811bbcd6..e2044099c2 100644
--- a/mlnode/iotdb/mlnode/data_access/offline/source.py
+++ b/mlnode/iotdb/mlnode/data_access/offline/source.py
@@ -18,7 +18,6 @@
import numpy as np
import pandas as pd
-from iotdb.mlnode import serde
from iotdb.mlnode.client import client_manager
diff --git a/mlnode/iotdb/mlnode/parser.py b/mlnode/iotdb/mlnode/parser.py
index 8788885910..294f6af87b 100644
--- a/mlnode/iotdb/mlnode/parser.py
+++ b/mlnode/iotdb/mlnode/parser.py
@@ -17,10 +17,9 @@
#
-import re
import argparse
-
-from typing import List, Dict, Tuple
+import re
+from typing import Dict, List, Tuple
from iotdb.mlnode.algorithm.enums import ForecastTaskType
from iotdb.mlnode.data_access.enums import DatasetType, DataSourceType
diff --git a/mlnode/iotdb/mlnode/storage.py b/mlnode/iotdb/mlnode/storage.py
index 78ecb351de..84d7dfd7ed 100644
--- a/mlnode/iotdb/mlnode/storage.py
+++ b/mlnode/iotdb/mlnode/storage.py
@@ -19,11 +19,12 @@
import json
import os
import shutil
+from typing import Dict, Tuple
import torch
import torch.nn as nn
from pylru import lrucache
-from typing import Dict, Tuple
+
from iotdb.mlnode.config import descriptor
from iotdb.mlnode.exception import ModelNotExistError
from iotdb.mlnode.log import logger