|
|
|
@@ -32,7 +32,7 @@ def main(argv = None): |
|
|
|
extractor = NumpyClient(f.src.url).stream_extract_numpy |
|
|
|
inserter = NumpyClient(f.dest.url).stream_insert_numpy_context |
|
|
|
for i in f.intervals(): |
|
|
|
print "Processing", f.interval_string(i) |
|
|
|
print "Processing", i.human_string() |
|
|
|
with inserter(f.dest.path, i.start, i.end) as insert_ctx: |
|
|
|
for data in extractor(f.src.path, i.start, i.end): |
|
|
|
insert_ctx.insert(data) |
|
|
|
|
