data-maker/pipeline.py

#!/usr/bin/env python3
	@staticmethod
		df = pd.read_gbq(SQL,credentials=credentials,dialect='standard')
			else:
		
				
		
		# base_cols = list(set(_args['data'].columns) - set(args['columns']))	#-- rebuilt the dataset (and store it)
		# cols = _dc.columns.tolist()
		# for name in cols :
		# 	_args['data'][name] = _dc[name]
	
	
				
		# 	# args['gpu']
		# 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)