You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sdap.apache.org by tl...@apache.org on 2021/05/05 17:16:32 UTC
[incubator-sdap-ingester] 01/01: add default case when collection
path is a regex
This is an automated email from the ASF dual-hosted git repository.
tloubrieu pushed a commit to branch watch_file_inregex_309
in repository https://gitbox.apache.org/repos/asf/incubator-sdap-ingester.git
commit 9477e49e50125a9e39879c45d3c8bae09485804b
Author: thomas loubrieu <th...@jpl.nasa.gov>
AuthorDate: Wed May 5 10:16:10 2021 -0700
add default case when collection path is a regex
---
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: