diff --git a/pipeline.py b/pipeline.py
index 4985156..2b5f028 100644
--- a/pipeline.py
+++ b/pipeline.py
@@ -166,8 +166,11 @@ class Components :
 		_args['continuous']= args['continuous'] if 'continuous' in args else []
 		#
 		# How many rows sub-partition must we divide this into ?
-		# -- Let us tray assessing
-		
+		#	let us fix the data types here every _id field will be an np.int64...
+		#
+		for name in df.columns.tolist():
+			if name.endwith('_id') :
+				df[name] = df[name].astype(np.int64)
 		
 		
 		_dc = pd.DataFrame()