__database__.publish_stop()
// Here we should Wait for any channel if it has still data to receive in its channel
// Send manual stops to the process not using channels
logsProcessQueue.put("stop_process")
try:
logsProcessQueue.put("stop_process")
except NameError:
// The logsProcessQueue is not there because we didnt started the logs files (used -l)
After Change
// If there are still modified TWs, just mark them as
// notmodified since we alredy "waited" on them
for profileTW in TWModifiedforProfile:
profileid = profileTW.split(fieldseparator)[0] + fieldseparator + profileTW.split(fieldseparator)[1]
twid = profileTW.split(fieldseparator)[2]
__database__.markProfileTWAsNotModifiedLogs(profileid, twid)
// outputProcessQueue.put("11|Main|[Main] Back to 0")
