v2.2.0
Steve Nyemba 5 days ago
parent 3b9203c0a0
commit f035f70fa0

@ -111,7 +111,7 @@ class IETL(IReader) :
def read(self,**_args): def read(self,**_args):
_key = 'cmd' if 'cmd' in self._source else 'query' _key = 'cmd' if 'cmd' in self._source else 'query'
_kwargs = self._source[_key] if _key in self._source else None _kwargs = self._source[_key] if _key in self._source else None
_data = super().read(**_kwargs) _data = super().read(**_kwargs) if _kwargs else super().read()
for _kwargs in self._targets : for _kwargs in self._targets :
self.post(_data,**_kwargs) self.post(_data,**_kwargs)
@ -127,6 +127,6 @@ class IETL(IReader) :
# if 'schema' in _args : # if 'schema' in _args :
# writer.write(_data,schema=_args['schema']) # writer.write(_data,schema=_args['schema'])
# else: # else:
print ("writing .... ",_data.shape)
writer.write(_data) writer.write(_data)
writer.close() writer.close()
Loading…
Cancel
Save