data-maker/pipeline.py

#!/usr/bin/env python3
	@staticmethod
		df = pd.read_gbq(SQL,credentials=credentials,dialect='standard')
		else :
		if 'ignore' in args and 'columns' in args['ignore'] :

			skip_columns = []
			_schema = schema
				
						pass
				if _schema :
					writer.write(_df[cols],schema=_schema,table=args['from'])
				else:
					writer.write(_df[cols],table=args['from'])
		# folder = os.sep.join([args['logs'],args['context'],partition,'output']) 
		# if 'file' in args :

	#process.start()