QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-18 13:10:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

CE-781 Updated logging in filesystem importer

Browse Source
This commit is contained in:
darin.kelkhoff
2024-02-21 09:03:04 -06:00
parent 3b8eef0f9c
commit b506150842
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
qqq-backend-module-filesystem/src/main/java/com/kingsrook/qqq/backend/module/filesystem/processes/implementations/filesystem/importer/FilesystemImporterStep.java
View File

@ -164,6 +164,7 @@ public class FilesystemImporterStep implements BackendStep
try try
{ {
String sourceFileName = sourceEntry.getKey(); String sourceFileName = sourceEntry.getKey();
LOG.info("Found file", logPair("fileName", sourceFileName));
///////////////////////////////////////////////////////// /////////////////////////////////////////////////////////
// if filename was already imported, decide what to do // // if filename was already imported, decide what to do //
@ -183,7 +184,7 @@ public class FilesystemImporterStep implements BackendStep
} }
else else
{ {
LOG.debug("Skipping already-imported file", logPair("fileName", sourceFileName)); LOG.info("Skipping already-imported file", logPair("fileName", sourceFileName)); // todo - downgrade to debug?
removeSourceFileIfSoConfigured(removeFileAfterImport, sourceActionBase, sourceTable, sourceBackend, sourceFileName); removeSourceFileIfSoConfigured(removeFileAfterImport, sourceActionBase, sourceTable, sourceBackend, sourceFileName);
continue; continue;
} }
@ -317,8 +318,14 @@ public class FilesystemImporterStep implements BackendStep
if(removeFileAfterImport) if(removeFileAfterImport)
{ {
String fullBasePath = sourceActionBase.getFullBasePath(sourceTable, sourceBackend); String fullBasePath = sourceActionBase.getFullBasePath(sourceTable, sourceBackend);
LOG.info("Removing source file", logPair("path", fullBasePath + "/" + sourceFileName), logPair("sourceTable", sourceTable.getName()));
sourceActionBase.deleteFile(QContext.getQInstance(), sourceTable, fullBasePath + "/" + sourceFileName); sourceActionBase.deleteFile(QContext.getQInstance(), sourceTable, fullBasePath + "/" + sourceFileName);
} }
else
{
// todo - downgrade to debug
LOG.info("Not configured to remove source file", logPair("sourceFileName", sourceFileName), logPair("sourceTable", sourceTable.getName()));
}
} }