in src/WebJobs.Extensions/Extensions/Files/Listener/FileProcessor.cs [249:276]
public virtual bool ShouldProcessFile(string filePath)
{
if (IsStatusFile(filePath))
{
return false;
}
string statusFilePath = GetStatusFile(filePath);
if (!File.Exists(statusFilePath))
{
return true;
}
StatusFileEntry statusEntry = null;
try
{
GetLastStatus(statusFilePath, out statusEntry);
}
catch (IOException)
{
// if we get an exception reading the status file, it's
// likely because someone started processing and has it locked
return false;
}
return statusEntry == null || (statusEntry.State != ProcessingState.Processed &&
statusEntry.ProcessCount < MaxProcessCount);
}