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'] :

			real_df = args['data'][x_cols].copy()
				
		
	
		# 		args['data'] = DATA[index]
		# print (["Started ",len(jobs),"trainers" if len(jobs)>1 else "trainer" ])
		# while len(jobs)> 0 :
		# 	jobs = [job for job in jobs if job.is_alive()]
		# 	time.sleep(2)