diff --git a/src/opnsense/scripts/netflow/lib/aggregates/__init__.py b/src/opnsense/scripts/netflow/lib/aggregates/__init__.py
index 84b76cb3f..34d02635d 100644
--- a/src/opnsense/scripts/netflow/lib/aggregates/__init__.py
+++ b/src/opnsense/scripts/netflow/lib/aggregates/__init__.py
@@ -32,6 +32,8 @@ import glob
 import syslog
 import datetime
 import sqlite3
+from lib.aggregate import convert_timestamp
+sqlite3.register_converter('timestamp', convert_timestamp)
 
 
 class BaseFlowAggregator(object):