This is an automated email from the ASF dual-hosted git repository.
jfeinauer pushed a commit to branch feature/improve-py-logging
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/feature/improve-py-logging by
this push:
new 1c5b5da [CLIENT-PY] Applied flake8 and black for reformatting.
1c5b5da is described below
commit 1c5b5da95634823b16e3b1fc9da25265e18d2969
Author: Julian Feinauer <[email protected]>
AuthorDate: Sun Apr 4 10:50:38 2021 +0200
[CLIENT-PY] Applied flake8 and black for reformatting.
---
client-py/iotdb/Session.py | 34 +++++++++++++++++++++++---------
client-py/iotdb/utils/IoTDBRpcDataSet.py | 8 ++++++--
client-py/iotdb/utils/SessionDataSet.py | 1 +
client-py/iotdb/utils/Tablet.py | 4 +++-
4 files changed, 35 insertions(+), 12 deletions(-)
diff --git a/client-py/iotdb/Session.py b/client-py/iotdb/Session.py
index e2ef78e..5db100a 100644
--- a/client-py/iotdb/Session.py
+++ b/client-py/iotdb/Session.py
@@ -149,7 +149,7 @@ class Session(object):
except TTransport.TException as e:
logger.exception(
"Error occurs when closing session at server. Maybe server is
down. Error message: ",
- exc_info=e
+ exc_info=e,
)
finally:
self.__is_close = True
@@ -162,7 +162,9 @@ class Session(object):
:param group_name: String, storage group name (starts from root)
"""
status = self.__client.setStorageGroup(self.__session_id, group_name)
- logger.debug("setting storage group {} message: {}".format(group_name,
status.message))
+ logger.debug(
+ "setting storage group {} message: {}".format(group_name,
status.message)
+ )
return Session.verify_success(status)
@@ -203,7 +205,9 @@ class Session(object):
self.__session_id, ts_path, data_type, encoding, compressor
)
status = self.__client.createTimeseries(request)
- logger.debug("creating time series {} message: {}".format(ts_path,
status.message))
+ logger.debug(
+ "creating time series {} message: {}".format(ts_path,
status.message)
+ )
return Session.verify_success(status)
@@ -267,7 +271,9 @@ class Session(object):
request = TSDeleteDataReq(self.__session_id, paths_list, timestamp)
try:
status = self.__client.deleteData(request)
- logger.debug("delete data from {}, message: {}".format(paths_list,
status.message))
+ logger.debug(
+ "delete data from {}, message: {}".format(paths_list,
status.message)
+ )
except TTransport.TException as e:
logger.exception("data deletion fails because: ", e)
@@ -388,7 +394,9 @@ class Session(object):
device_ids, times, measurements_lst, type_values_lst, values_lst
)
status = self.__client.testInsertRecords(request)
- logger.debug("testing! insert multiple records, message:
{}".format(status.message))
+ logger.debug(
+ "testing! insert multiple records, message:
{}".format(status.message)
+ )
return Session.verify_success(status)
@@ -396,7 +404,9 @@ class Session(object):
self, device_id, timestamp, measurements, data_types, values
):
if (len(values) != len(data_types)) or (len(values) !=
len(measurements)):
- raise RuntimeError("length of data types does not equal to length
of values!")
+ raise RuntimeError(
+ "length of data types does not equal to length of values!"
+ )
values_in_bytes = Session.value_to_bytes(data_types, values)
return TSInsertRecordReq(
self.__session_id, device_id, measurements, values_in_bytes,
timestamp
@@ -406,7 +416,9 @@ class Session(object):
self, device_id, timestamp, measurements, data_types, values
):
if (len(values) != len(data_types)) or (len(values) !=
len(measurements)):
- raise RuntimeError("length of data types does not equal to length
of values!")
+ raise RuntimeError(
+ "length of data types does not equal to length of values!"
+ )
return TSInsertStringRecordReq(
self.__session_id, device_id, measurements, values, timestamp
)
@@ -514,7 +526,9 @@ class Session(object):
# check sorted
if not Session.check_sorted(times_list):
- raise RuntimeError("insert records of one device error: timestamp
not sorted")
+ raise RuntimeError(
+ "insert records of one device error: timestamp not sorted"
+ )
request = self.gen_insert_records_of_one_device_request(
device_id, times_list, measurements_list, values_list, types_list
@@ -573,7 +587,9 @@ class Session(object):
status = self.__client.testInsertTablets(
self.gen_insert_tablets_req(tablet_list)
)
- logger.debug("testing! insert multiple tablets, message:
{}".format(status.message))
+ logger.debug(
+ "testing! insert multiple tablets, message:
{}".format(status.message)
+ )
return Session.verify_success(status)
diff --git a/client-py/iotdb/utils/IoTDBRpcDataSet.py
b/client-py/iotdb/utils/IoTDBRpcDataSet.py
index 1dd6cb5..f71b5d9 100644
--- a/client-py/iotdb/utils/IoTDBRpcDataSet.py
+++ b/client-py/iotdb/utils/IoTDBRpcDataSet.py
@@ -117,7 +117,9 @@ class IoTDBRpcDataSet(object):
)
)
except TTransport.TException as e:
- raise RuntimeError("close session {} failed because:
".format(self.__session_id), e)
+ raise RuntimeError(
+ "close session {} failed because:
".format(self.__session_id), e
+ )
self.__is_closed = True
self.__client = None
@@ -198,7 +200,9 @@ class IoTDBRpcDataSet(object):
self.__query_data_set = resp.queryDataSet
return resp.hasResultSet
except TTransport.TException as e:
- raise RuntimeError("Cannot fetch result from server, because of
network connection: ", e)
+ raise RuntimeError(
+ "Cannot fetch result from server, because of network
connection: ", e
+ )
def is_null(self, index, row_num):
bitmap = self.__current_bitmap[index]
diff --git a/client-py/iotdb/utils/SessionDataSet.py
b/client-py/iotdb/utils/SessionDataSet.py
index 1bc421a..f0f7266 100644
--- a/client-py/iotdb/utils/SessionDataSet.py
+++ b/client-py/iotdb/utils/SessionDataSet.py
@@ -29,6 +29,7 @@ import pandas as pd
logger = logging.getLogger("IoTDB")
+
class SessionDataSet(object):
def __init__(
self,
diff --git a/client-py/iotdb/utils/Tablet.py b/client-py/iotdb/utils/Tablet.py
index b6391b1..667adcb 100644
--- a/client-py/iotdb/utils/Tablet.py
+++ b/client-py/iotdb/utils/Tablet.py
@@ -40,7 +40,9 @@ class Tablet(object):
:param timestamps: List.
"""
if len(timestamps) != len(values):
- raise RuntimeError("Input error! len(timestamps) does not equal to
len(values)!")
+ raise RuntimeError(
+ "Input error! len(timestamps) does not equal to len(values)!"
+ )
if not Tablet.check_sorted(timestamps):
sorted_zipped = sorted(zip(timestamps, values))
