bug fix: schema

This commit is contained in:
Steve Nyemba 2022-08-10 10:56:40 -05:00
parent 44d3f4989a
commit 3aee3e2cae
1 changed files with 9 additions and 9 deletions

View File

@ -46,15 +46,15 @@ class Input :
:param store data-store parameters/configuration
:param sql sql query that pulls a representative sample of the data
"""
self._schema = _args['schema'] if 'schema' in _args else {}
#
# schema data should be in a hash map for these purposes
#
if self._schema :
r = {}
for _item in self._schema :
r[_item['name']] = r[_item['type']]
self._schema = r
# self._schema = _args['schema'] if 'schema' in _args else {}
# #
# # schema data should be in a hash map for these purposes
# #
# if self._schema :
# r = {}
# for _item in self._schema :
# r[_item['name']] = r[_item['type']]
# self._schema = r
self.df = _args['data']
if 'sql' not in _args :