diff --git a/src/py/crankshaft/crankshaft/analysis_data_provider.py b/src/py/crankshaft/crankshaft/analysis_data_provider.py index eb730ff..d942627 100644 --- a/src/py/crankshaft/crankshaft/analysis_data_provider.py +++ b/src/py/crankshaft/crankshaft/analysis_data_provider.py @@ -46,9 +46,9 @@ class AnalysisDataProvider: def get_nonspatial_kmeans(self, params): """fetch data for non-spatial kmeans""" - agg_cols = ', '.join(['array_agg({0}) As arr_col{1}'.format(idx+1, val) + agg_cols = ', '.join(['array_agg({0}) As arr_col{1}'.format(val, idx+1) for idx, val in enumerate(params['colnames'])]) - + print agg_cols query = ''' SELECT {cols}, array_agg({id_col}) As rowid FROM ({subquery}) As a