|
|
@ -492,12 +492,12 @@ class Generator (Learner):
|
|
|
|
if _store['provider'] == 'bigquery':
|
|
|
|
if _store['provider'] == 'bigquery':
|
|
|
|
try:
|
|
|
|
try:
|
|
|
|
_log['schema'] = _schema
|
|
|
|
_log['schema'] = _schema
|
|
|
|
writer.write(_df,schema=_schema,table=self.info['from'])
|
|
|
|
writer.write(_df,schema=_schema)
|
|
|
|
except Exception as e:
|
|
|
|
except Exception as e:
|
|
|
|
_log['schema'] = []
|
|
|
|
_log['schema'] = []
|
|
|
|
writer.write(_df,table=self.info['from'])
|
|
|
|
writer.write(_df)
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
writer.write(_df,table=self.info['from'])
|
|
|
|
writer.write(_df)
|
|
|
|
self.log(**_log)
|
|
|
|
self.log(**_log)
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
self.cache.append(_df)
|
|
|
|
self.cache.append(_df)
|
|
|
|