This is an automated email from the ASF dual-hosted git repository.
nchung pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-sdap-ingester.git
The following commit(s) were added to refs/heads/dev by this push:
new aeb1481 add default case when collection path is a regex (#32)
aeb1481 is described below
commit aeb14815424b7cdacba929d5f2474a486130769e
Author: thomas loubrieu <[email protected]>
AuthorDate: Thu May 6 17:03:00 2021 -0700
add default case when collection path is a regex (#32)
Co-authored-by: thomas loubrieu <[email protected]>
---
collection_manager/collection_manager/services/CollectionWatcher.py | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/collection_manager/collection_manager/services/CollectionWatcher.py
b/collection_manager/collection_manager/services/CollectionWatcher.py
index 68b013a..b713f2d 100644
--- a/collection_manager/collection_manager/services/CollectionWatcher.py
+++ b/collection_manager/collection_manager/services/CollectionWatcher.py
@@ -124,7 +124,10 @@ class CollectionWatcher:
def _get_files_at_path(self, path: str) -> List[str]:
if os.path.isfile(path):
return [path]
- return [f for f in glob(path + '/**', recursive=True) if
os.path.isfile(f)]
+ elif os.path.isdir(path):
+ return [f for f in glob(path + '/**', recursive=True) if
os.path.isfile(f)]
+ else:
+ return [f for f in glob(path, recursive=True) if os.path.isfile(f)]
async def _reload_and_reschedule(self):
try:
