From f3598efa0d3399516d4d4178671abe55605419de Mon Sep 17 00:00:00 2001
From: Steve Nyemba <nyemba@gmail.com>
Date: Tue, 17 May 2022 19:10:33 -0500
Subject: [PATCH] bug fix: date conversions

---
 data/maker/__init__.py | 49 +++++++++++++++++++++---------------------
 1 file changed, 25 insertions(+), 24 deletions(-)

diff --git a/data/maker/__init__.py b/data/maker/__init__.py
index d05509d..403255c 100644
--- a/data/maker/__init__.py
+++ b/data/maker/__init__.py
@@ -296,35 +296,35 @@ class Generator (Learner):
             name = _item['name']
             
             if _item['type'].upper() in ['DATE','DATETIME','TIMESTAMP'] :
-                FORMAT = '%m-%d-%Y'
+                FORMAT = '%Y-%m-%d'
                 
-                # try:
-                #     #
-                #     #-- Sometimes data isn't all it's meant to be
-                #     SIZE = -1
-                #     if 'format' in self.info and name in self.info['format'] :
-                #         FORMAT = self.info['format'][name]
-                #         SIZE = 10
-                #     elif _item['type'] in ['DATETIME','TIMESTAMP'] :
-                #             FORMAT = '%m-%d-%Y %H:%M:%S'
-                #             SIZE = 19
+                try:
+                    #
+                    #-- Sometimes data isn't all it's meant to be
+                    SIZE = -1
+                    if 'format' in self.info and name in self.info['format'] :
+                        FORMAT = self.info['format'][name]
+                        SIZE = 10
+                    elif _item['type'] in ['DATETIME','TIMESTAMP'] :
+                            FORMAT = '%Y-%m-%-d %H:%M:%S'
+                            SIZE = 19
                     
-                #     if SIZE > 0 :
+                    if SIZE > 0 :
                         
-                #         values = pd.to_datetime(_df[name], format=FORMAT).astype(str)
-                #         _df[name] = [_date[:SIZE].strip() for _date in values]
+                        values = pd.to_datetime(_df[name], format=FORMAT).astype(np.datetime64)
+                        # _df[name] = [_date[:SIZE].strip() for _date in values]
                         
                        
-                #     # _df[name] = _df[name].astype(str)
-                #     r[name] = FORMAT
-                #     # _df[name] = pd.to_datetime(_df[name], format=FORMAT) #.astype('datetime64[ns]')
-                #     if _item['type'] in ['DATETIME','TIMESTAMP']:                   
-                #         pass #;_df[name] = _df[name].fillna('').astype('datetime64[ns]')
+                    # _df[name] = _df[name].astype(str)
+                    r[name] = FORMAT
+                    # _df[name] = pd.to_datetime(_df[name], format=FORMAT) #.astype('datetime64[ns]')
+                    if _item['type'] in ['DATETIME','TIMESTAMP']:                   
+                        pass #;_df[name] = _df[name].fillna('').astype('datetime64[ns]')
                     
-                # except Exception as e:
-                #     pass
-                # finally:
-                #     pass
+                except Exception as e:
+                    pass
+                finally:
+                    pass
             else:
                 
                 #
@@ -387,10 +387,11 @@ class Generator (Learner):
 
             # w = transport.factory.instance(doc='observation',provider='mongodb',context='write',db='IOV01_LOGS',auth_file='/home/steve/dev/transport/mongo.json')
             # w.write(_df)
+            cols = [name for name in _df.columns if name.endswith('datetime')]
             # print (_df[cols])
             
             writer = transport.factory.instance(**_store)
-            writer.write(_df,schema=_schema)
+            writer.write(_df[cols],schema=[_item for _item in _schema if _item['name'] in cols])