Changeset: f8a016c9057b for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=f8a016c9057b
Modified Files:
clients/iotclient/requirements.txt
clients/iotclient/src/Streams/streams.py
Branch: iot
Log Message:
Updated requirements.txt file, removed mapi flush baskets call comment.
diffs (30 lines):
diff --git a/clients/iotclient/requirements.txt
b/clients/iotclient/requirements.txt
--- a/clients/iotclient/requirements.txt
+++ b/clients/iotclient/requirements.txt
@@ -1,4 +1,4 @@
-fake-factory>=0.5.7
+fake-factory>=0.5.8
Flask-RESTful>=0.3.5
IPy>=0.83
jsonschema>=2.5.1
diff --git a/clients/iotclient/src/Streams/streams.py
b/clients/iotclient/src/Streams/streams.py
--- a/clients/iotclient/src/Streams/streams.py
+++ b/clients/iotclient/src/Streams/streams.py
@@ -64,7 +64,7 @@ class BaseIOTStream:
if dirs:
for elem in dirs: # for each directory found, flush it
dir_path = os.path.join(self._base_path, str(elem))
- # mapi_flush_baskets(self._connection, self._schema_name,
self._stream_name, dir_path)
+ mapi_flush_baskets(self._connection, self._schema_name,
self._stream_name, dir_path)
self._baskets_counter = max(dirs) + 1 # increment current
basket number
else:
self._baskets_counter = 1
@@ -138,7 +138,7 @@ class BaseIOTStream:
def flush_baskets(self, last=False): # the monitor has to be acquired in
write mode before running this method!!!
# write the tuple count in the basket
- # mapi_flush_baskets(self._connection, self._schema_name,
self._stream_name, self._current_base_path)
+ mapi_flush_baskets(self._connection, self._schema_name,
self._stream_name, self._current_base_path)
if not last: # when stopping the stream, we don't want to continue to
create more baskets files
self._tuples_in_per_basket = 0
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
https://www.monetdb.org/mailman/listinfo/checkin-list
