data-maker/pipeline.py

#!/usr/bin/env python3
	@staticmethod
		df = pd.read_gbq(SQL,credentials=credentials,dialect='standard')
		else :


			
		
					_columns = set(df.columns) - set(_df.columns)											
		
	#
	# @TODO:
	#	Log what was initiated so we have context of this processing ...
	#
		# 	jobs = [job for job in jobs if job.is_alive()]
		# 	time.sleep(2)