comment sneakernet
parent
1bd0aa9419
commit
09134eaba4
|
@ -46,9 +46,11 @@ class _Importer(FileSystemEventHandler):
|
||||||
|
|
||||||
|
|
||||||
def sneakernet_import_thread():
|
def sneakernet_import_thread():
|
||||||
|
"""Add block data dir & confed paths to fs observer to watch for new bls"""
|
||||||
observer = Observer()
|
observer = Observer()
|
||||||
for path in watch_paths:
|
for path in watch_paths:
|
||||||
observer.schedule(_Importer(), path, recursive=True)
|
observer.schedule(_Importer(), path, recursive=True)
|
||||||
observer.start()
|
observer.start()
|
||||||
while observer.isAlive():
|
while observer.isAlive():
|
||||||
|
# call import func with timeout
|
||||||
observer.join(60)
|
observer.join(60)
|
Loading…
Reference in New Issue