Fix to_datetime function

hi-primus · Sep 3, 2021 · e71442b · e71442b
1 parent 8b3aec6
commit e71442b
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/optimus/engines/base/pandas/functions.py b/optimus/engines/base/pandas/functions.py
@@ -1,4 +1,5 @@
 
+from optimus.helpers.logger import logger
 import numpy as np
 import pandas as pd
 from fastnumbers import isintlike, isfloat, isreal, fast_forceint, fast_float
@@ -80,10 +81,12 @@ def _to_float(cls, series):
 
     @classmethod
     def _to_datetime(cls, value, format=None):
-        if format is None:
-            return cls._partition_engine.to_datetime(value, errors="coerce")
-        else:
-            return cls._partition_engine.to_datetime(value, format=format, errors="coerce")
+        try:
+            if format is not None:
+                return cls._partition_engine.to_datetime(value, format=format, errors="coerce")
+        except Exception as e:
+            logger.warn(e)
+        return cls._partition_engine.to_datetime(value, errors="coerce")
 
     @classmethod
     def format_date(cls, series, current_format=None, output_format=None):