# License for the specific language governing permissions and limitations
# under the License.
+import logging
+
from datetime import datetime
from fluent import sender
-import logging
import pytz
def start_new_run(self):
'''Delimitate a new run in the stream of records with a new timestamp
'''
- self.runlogdate = str(datetime.now())
+ self.runlogdate = self.__get_timestamp()
# reset counters
self.__warning_counter = 0
self.__error_counter = 0
self.__update_stats(record.levelno)
self.sender.emit(None, data)
+ # this function is called by summarizer
+ def record_send(self, record):
+ self.sender.emit(None, record)
+
# send START record for each run
def __send_start_record(self):
data = {
return "GOOD RUN"
elif highest_level == logging.WARNING:
return "RUN WITH WARNINGS"
- else:
- return "RUN WITH ERRORS"
+ return "RUN WITH ERRORS"
def __update_stats(self, levelno):
if levelno == logging.WARNING: