  			WHERE EXISTS (
 				SELECT 1 FROM datapoint d
 				WHERE d.region_id = rg.id
-				AND d.cache_job_id = $1
+				AND d.cache_job_id = 7130
 			)
 
 		  	UNION ALL

		INNER JOIN _campaign_indicator ci
			ON d.indicator_id = ci.indicator_id
			AND d.campaign_id = ci.campaign_id;


		DROP TABLE IF EXISTS _tmp_agg;
		CREATE TABLE _tmp_agg AS

		AND ta.campaign_id = d.campaign_id
		AND ta.indicator_id = d.indicator_id;


		--- UPDATE THE REST OF THE DATAPOINT TABLE --

		UPDATE datapoint d
		SET cache_job_id = $1
		WHERE d.id in (
			SELECT datapoint_id
			FROM _to_agg ta
			WHERE ta.datapoint_id IS NOT NULL
		);

		-- UPDATE EXISTING --
		UPDATE agg_datapoint ad
