translate: improve ToInteger implementation

opencybersecurityalliance · Aug 21, 2023 · 7ab26a9 · 7ab26a9
1 parent ffb85db
commit 7ab26a9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/firepit/aio/ingest.py b/firepit/aio/ingest.py
@@ -305,7 +305,7 @@ def translate(
         logger.debug('transform: %s %s', txf_col, txf_name)
         # Accelerate common transforms
         if txf_name == 'ToInteger':
-            df[txf_col] = df[txf_col].dropna().astype('int')
+            df[txf_col] = pd.to_numeric(df[txf_col]).dropna().astype('int')
         elif txf_name == 'EpochToTimestamp':  # QRadar, QDL
             df[txf_col] = (pd.to_datetime(df[txf_col].astype(int),
                                           unit="ms",