# Interconnection Queue Monitor (`springstea/interconnection-queue-monitor`) Actor
Monitors US grid interconnection queues (CAISO, PJM, MISO) and reports every project change as structured data: new applications, withdrawals, capacity and COD changes, study-phase progress. Filter by fuel, state and size.
- **URL**: https://apify.com/springstea/interconnection-queue-monitor.md
- **Developed by:** [Kasım Genç](https://apify.com/springstea) (community)
- **Categories:** Business, Automation, Lead generation
- **Stats:** 2 total users, 1 monthly users, 100.0% runs succeeded, 0 bookmarks
- **User rating**: No ratings yet
## Pricing
from $5.00 / 1,000 results
This Actor is paid per event. You are not charged for the Apify platform usage, but only a fixed price for specific events.
Learn more: https://docs.apify.com/platform/actors/running/actors-in-store#pay-per-event
## What's an Apify Actor?
Actors are a software tools running on the Apify platform, for all kinds of web data extraction and automation use cases.
In Batch mode, an Actor accepts a well-defined JSON input, performs an action which can take anything from a few seconds to a few hours,
and optionally produces a well-defined JSON output, datasets with results, or files in key-value store.
In Standby mode, an Actor provides a web server which can be used as a website, API, or an MCP server.
Actors are written with capital "A".
## How to integrate an Actor?
If asked about integration, you help developers integrate Actors into their projects.
You adapt to their stack and deliver integrations that are safe, well-documented, and production-ready.
The best way to integrate Actors is as follows.
In JavaScript/TypeScript projects, use official [JavaScript/TypeScript client](https://docs.apify.com/api/client/js/docs.md):
```bash
npm install apify-client
```
In Python projects, use official [Python client library](https://docs.apify.com/api/client/python/docs.md):
```bash
pip install apify-client
```
In shell scripts, use [Apify CLI](https://docs.apify.com/cli/docs.md):
````bash
# MacOS / Linux
curl -fsSL https://apify.com/install-cli.sh | bash
# Windows
irm https://apify.com/install-cli.ps1 | iex
```bash
In AI frameworks, you might use the [Apify MCP server](https://docs.apify.com/integrations/mcp.md).
If your project is in a different language, use the [REST API](https://docs.apify.com/api/v2.md).
For usage examples, see the [API](#api) section below.
For more details, see Apify documentation as [Markdown index](https://docs.apify.com/llms.txt) and [Markdown full-text](https://docs.apify.com/llms-full.txt).
# README
## Interconnection Queue Monitor
Monitors US grid **interconnection queues** — the official waiting lists of every power plant and battery project seeking to connect to the grid — and reports each change as structured data:
- "A new 200 MW battery project entered the PJM queue in Ohio."
- "This solar project moved from Phase 1 to GIA — it's getting real."
- "Competitor X's project was withdrawn." / "Project Y just reached commercial operation."
- "The proposed COD slipped two years."
**Coverage:** CAISO (California), PJM (13 Mid-Atlantic/Midwest states), MISO (15 Central US states) — together roughly 15,000 tracked queue positions. Sources are the ISOs' official public queue reports. (ERCOT, NYISO, ISO-NE are on the roadmap; their downloads sit behind aggressive bot protection.)
### Who uses this
- **Project developers** — track competing projects near your POI, spot withdrawals that free up headroom.
- **Land agents & site originators** — new queue entries reveal who is developing where, months before permits.
- **Equipment vendors & EPCs** — projects advancing to later study phases are buying signals.
- **Investors & analysts** — queue trends by fuel/region without manually diffing spreadsheets.
### How it works
Each run downloads the current queue from every selected ISO, normalizes projects into a common shape, and diffs them against the snapshot from the previous run (kept in a named key-value store). Only changes matching your filters are output. Schedule it **daily or weekly** for a continuous feed.
- The first run per ISO establishes the baseline (silent by default — see `emitBaselineRecords`).
- If an ISO's download fails, its snapshot stays untouched and the other ISOs still process — a flaky source can't produce phantom changes.
- Withdrawn-to-withdrawn noise is suppressed unless you opt in (`includeWithdrawn`).
### Input
```json
{
"isos": ["CAISO", "PJM", "MISO"],
"fuels": ["solar", "battery", "hybrid"],
"states": ["CA", "OH", "IL"],
"minCapacityMW": 50,
"emitBaselineRecords": false
}
````
| Field | Type | Description |
|---|---|---|
| `isos` \* | `string[]` | `CAISO`, `PJM`, `MISO` (any subset). |
| `fuels` | `string[]` | `solar`, `wind`, `battery`, `hybrid` (co-located, e.g. solar+storage), `gas`, `nuclear`, `hydro`, `geothermal`, `biomass`, `coal`, `oil`, `other`. Empty = all. |
| `states` | `string[]` | 2-letter codes. Empty = all. |
| `minCapacityMW` | `integer` | Minimum project size. Default 0. |
| `includeWithdrawn` | `boolean` | Also track projects that are already withdrawn. Transitions *into* withdrawn are always reported. Default `false`. |
| `emitBaselineRecords` | `boolean` | Push all matching projects as `baseline` on the first run. Queues are large (PJM ~9,000 rows) — leave off unless you want the full current picture. Default `false`. |
| `snapshotStoreName` | `string` | Named KV store for snapshots between runs. |
### Output
One dataset record per changed project, largest capacity first:
```json
{
"iso": "CAISO",
"queueId": "CAISO-17",
"projectName": "SONORAN 2",
"state": "CA",
"county": "RIVERSIDE",
"utility": "SCE",
"poi": "Colorado River Substation 230 kV",
"fuel": "hybrid",
"fuelRaw": "Photovoltaic + Battery",
"capacityMW": 400,
"status": "withdrawn",
"previousStatus": "active",
"statusRaw": "WITHDRAWN",
"studyPhase": "IA: Executed",
"queueDate": "2019-04-10",
"proposedCOD": "2027-06-01",
"changeType": "project_withdrawn",
"changes": [
{ "field": "status", "kind": "status_changed", "old": "active", "new": "withdrawn" }
],
"queueUrl": "https://www.caiso.com/library/public-queue-report",
"detectedAt": "2026-07-10T15:41:05.892Z",
"source": "CAISO public interconnection queue"
}
```
#### `changeType` values
| Value | Meaning |
|---|---|
| `baseline` | First run for an ISO — current state of a project (opt-in). |
| `new_project` | New queue entry appeared. |
| `project_withdrawn` | Project left the queue (withdrawn/retracted/canceled). |
| `project_in_service` | Project reached commercial operation. |
| `project_suspended` | Project suspended. |
| `status_changed` | Other status transition. |
| `capacity_changed` | MW figure changed (see `oldCapacityMW`). |
| `cod_changed` | Proposed/actual commercial operation date changed (see `previousCOD`). |
| `phase_changed` | Study phase / interconnection agreement status advanced. |
| `project_updated` | Other material change (POI, name, transmission owner). |
| `removed_from_queue` | Row disappeared from the source report entirely. |
The run summary (per-ISO counts, failures) is stored under the `OUTPUT` key of the default key-value store.
### Data sources & update cadence
| ISO | Source | Typical update |
|---|---|---|
| CAISO | [Public Queue Report (XLSX)](https://www.caiso.com/library/public-queue-report) | ~monthly |
| PJM | [Planning API queue export (XLSX)](https://www.pjm.com/planning/service-requests/serial-service-request-status) | ~daily |
| MISO | [GI Queue API (JSON)](https://www.misoenergy.org/planning/generator-interconnection/GI_Queue/gi-interactive-queue/) | ~weekly |
Daily scheduling is safe — unchanged sources simply produce zero records.
# Actor input Schema
## `isos` (type: `array`):
Which interconnection queues to monitor. Supported: CAISO (California), PJM (Mid-Atlantic/Midwest, 13 states), MISO (Central US, 15 states). ERCOT, NYISO and ISO-NE are on the roadmap (their sources sit behind aggressive bot protection).
## `fuels` (type: `array`):
Only report projects with these fuels. Slugs: solar, wind, battery, hybrid (co-located, e.g. solar+storage), gas, nuclear, hydro, geothermal, biomass, coal, oil, other. Empty = all fuels.
## `states` (type: `array`):
Only report projects in these states (2-letter codes, e.g. TX, CA, IL). Empty = all states.
## `minCapacityMW` (type: `integer`):
Only report projects at or above this size. 0 = no minimum.
## `includeWithdrawn` (type: `boolean`):
Transitions INTO withdrawn status are always reported. Enable this to also include projects that were already withdrawn (baseline records and updates on withdrawn projects).
## `emitBaselineRecords` (type: `boolean`):
On the first run for an ISO there is nothing to compare against. When enabled, every project matching your filters is pushed with changeType baseline. Caution: queues are large (PJM ~9,000, MISO ~3,800 rows) — with no filters this produces thousands of results. Default off.
## `snapshotStoreName` (type: `string`):
Named key-value store keeping per-ISO snapshots between runs.
## `proxyConfiguration` (type: `object`):
Optional proxies for the queue downloads.
## Actor input object example
```json
{
"isos": [
"CAISO",
"PJM",
"MISO"
],
"fuels": [],
"states": [],
"minCapacityMW": 0,
"includeWithdrawn": false,
"emitBaselineRecords": false,
"snapshotStoreName": "interconnection-queue-monitor"
}
```
# API
You can run this Actor programmatically using our API. Below are code examples in JavaScript, Python, and CLI, as well as the OpenAPI specification and MCP server setup.
## JavaScript example
```javascript
import { ApifyClient } from 'apify-client';
// Initialize the ApifyClient with your Apify API token
// Replace the '' with your token
const client = new ApifyClient({
token: '',
});
// Prepare Actor input
const input = {
"isos": [
"CAISO",
"PJM",
"MISO"
]
};
// Run the Actor and wait for it to finish
const run = await client.actor("springstea/interconnection-queue-monitor").call(input);
// Fetch and print Actor results from the run's dataset (if any)
console.log('Results from dataset');
console.log(`💾 Check your data here: https://console.apify.com/storage/datasets/${run.defaultDatasetId}`);
const { items } = await client.dataset(run.defaultDatasetId).listItems();
items.forEach((item) => {
console.dir(item);
});
// 📚 Want to learn more 📖? Go to → https://docs.apify.com/api/client/js/docs
```
## Python example
```python
from apify_client import ApifyClient
# Initialize the ApifyClient with your Apify API token
# Replace '' with your token.
client = ApifyClient("")
# Prepare the Actor input
run_input = { "isos": [
"CAISO",
"PJM",
"MISO",
] }
# Run the Actor and wait for it to finish
run = client.actor("springstea/interconnection-queue-monitor").call(run_input=run_input)
# Fetch and print Actor results from the run's dataset (if there are any)
print("💾 Check your data here: https://console.apify.com/storage/datasets/" + run["defaultDatasetId"])
for item in client.dataset(run["defaultDatasetId"]).iterate_items():
print(item)
# 📚 Want to learn more 📖? Go to → https://docs.apify.com/api/client/python/docs/quick-start
```
## CLI example
```bash
echo '{
"isos": [
"CAISO",
"PJM",
"MISO"
]
}' |
apify call springstea/interconnection-queue-monitor --silent --output-dataset
```
## MCP server setup
```json
{
"mcpServers": {
"apify": {
"command": "npx",
"args": [
"mcp-remote",
"https://mcp.apify.com/?tools=springstea/interconnection-queue-monitor",
"--header",
"Authorization: Bearer "
]
}
}
}
```
## OpenAPI specification
```json
{
"openapi": "3.0.1",
"info": {
"title": "Interconnection Queue Monitor",
"description": "Monitors US grid interconnection queues (CAISO, PJM, MISO) and reports every project change as structured data: new applications, withdrawals, capacity and COD changes, study-phase progress. Filter by fuel, state and size.",
"version": "0.1",
"x-build-id": "yYL2CBnIG2OUltbIq"
},
"servers": [
{
"url": "https://api.apify.com/v2"
}
],
"paths": {
"/acts/springstea~interconnection-queue-monitor/run-sync-get-dataset-items": {
"post": {
"operationId": "run-sync-get-dataset-items-springstea-interconnection-queue-monitor",
"x-openai-isConsequential": false,
"summary": "Executes an Actor, waits for its completion, and returns Actor's dataset items in response.",
"tags": [
"Run Actor"
],
"requestBody": {
"required": true,
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/inputSchema"
}
}
}
},
"parameters": [
{
"name": "token",
"in": "query",
"required": true,
"schema": {
"type": "string"
},
"description": "Enter your Apify token here"
}
],
"responses": {
"200": {
"description": "OK"
}
}
}
},
"/acts/springstea~interconnection-queue-monitor/runs": {
"post": {
"operationId": "runs-sync-springstea-interconnection-queue-monitor",
"x-openai-isConsequential": false,
"summary": "Executes an Actor and returns information about the initiated run in response.",
"tags": [
"Run Actor"
],
"requestBody": {
"required": true,
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/inputSchema"
}
}
}
},
"parameters": [
{
"name": "token",
"in": "query",
"required": true,
"schema": {
"type": "string"
},
"description": "Enter your Apify token here"
}
],
"responses": {
"200": {
"description": "OK",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/runsResponseSchema"
}
}
}
}
}
}
},
"/acts/springstea~interconnection-queue-monitor/run-sync": {
"post": {
"operationId": "run-sync-springstea-interconnection-queue-monitor",
"x-openai-isConsequential": false,
"summary": "Executes an Actor, waits for completion, and returns the OUTPUT from Key-value store in response.",
"tags": [
"Run Actor"
],
"requestBody": {
"required": true,
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/inputSchema"
}
}
}
},
"parameters": [
{
"name": "token",
"in": "query",
"required": true,
"schema": {
"type": "string"
},
"description": "Enter your Apify token here"
}
],
"responses": {
"200": {
"description": "OK"
}
}
}
}
},
"components": {
"schemas": {
"inputSchema": {
"type": "object",
"required": [
"isos"
],
"properties": {
"isos": {
"title": "Grid operators (ISOs)",
"type": "array",
"description": "Which interconnection queues to monitor. Supported: CAISO (California), PJM (Mid-Atlantic/Midwest, 13 states), MISO (Central US, 15 states). ERCOT, NYISO and ISO-NE are on the roadmap (their sources sit behind aggressive bot protection).",
"items": {
"type": "string"
}
},
"fuels": {
"title": "Fuel / technology filter",
"type": "array",
"description": "Only report projects with these fuels. Slugs: solar, wind, battery, hybrid (co-located, e.g. solar+storage), gas, nuclear, hydro, geothermal, biomass, coal, oil, other. Empty = all fuels.",
"default": [],
"items": {
"type": "string"
}
},
"states": {
"title": "State filter",
"type": "array",
"description": "Only report projects in these states (2-letter codes, e.g. TX, CA, IL). Empty = all states.",
"default": [],
"items": {
"type": "string"
}
},
"minCapacityMW": {
"title": "Minimum capacity (MW)",
"minimum": 0,
"type": "integer",
"description": "Only report projects at or above this size. 0 = no minimum.",
"default": 0
},
"includeWithdrawn": {
"title": "Include already-withdrawn projects",
"type": "boolean",
"description": "Transitions INTO withdrawn status are always reported. Enable this to also include projects that were already withdrawn (baseline records and updates on withdrawn projects).",
"default": false
},
"emitBaselineRecords": {
"title": "Emit baseline records on first run",
"type": "boolean",
"description": "On the first run for an ISO there is nothing to compare against. When enabled, every project matching your filters is pushed with changeType baseline. Caution: queues are large (PJM ~9,000, MISO ~3,800 rows) — with no filters this produces thousands of results. Default off.",
"default": false
},
"snapshotStoreName": {
"title": "Snapshot store name",
"type": "string",
"description": "Named key-value store keeping per-ISO snapshots between runs.",
"default": "interconnection-queue-monitor"
},
"proxyConfiguration": {
"title": "Proxy configuration",
"type": "object",
"description": "Optional proxies for the queue downloads."
}
}
},
"runsResponseSchema": {
"type": "object",
"properties": {
"data": {
"type": "object",
"properties": {
"id": {
"type": "string"
},
"actId": {
"type": "string"
},
"userId": {
"type": "string"
},
"startedAt": {
"type": "string",
"format": "date-time",
"example": "2025-01-08T00:00:00.000Z"
},
"finishedAt": {
"type": "string",
"format": "date-time",
"example": "2025-01-08T00:00:00.000Z"
},
"status": {
"type": "string",
"example": "READY"
},
"meta": {
"type": "object",
"properties": {
"origin": {
"type": "string",
"example": "API"
},
"userAgent": {
"type": "string"
}
}
},
"stats": {
"type": "object",
"properties": {
"inputBodyLen": {
"type": "integer",
"example": 2000
},
"rebootCount": {
"type": "integer",
"example": 0
},
"restartCount": {
"type": "integer",
"example": 0
},
"resurrectCount": {
"type": "integer",
"example": 0
},
"computeUnits": {
"type": "integer",
"example": 0
}
}
},
"options": {
"type": "object",
"properties": {
"build": {
"type": "string",
"example": "latest"
},
"timeoutSecs": {
"type": "integer",
"example": 300
},
"memoryMbytes": {
"type": "integer",
"example": 1024
},
"diskMbytes": {
"type": "integer",
"example": 2048
}
}
},
"buildId": {
"type": "string"
},
"defaultKeyValueStoreId": {
"type": "string"
},
"defaultDatasetId": {
"type": "string"
},
"defaultRequestQueueId": {
"type": "string"
},
"buildNumber": {
"type": "string",
"example": "1.0.0"
},
"containerUrl": {
"type": "string"
},
"usage": {
"type": "object",
"properties": {
"ACTOR_COMPUTE_UNITS": {
"type": "integer",
"example": 0
},
"DATASET_READS": {
"type": "integer",
"example": 0
},
"DATASET_WRITES": {
"type": "integer",
"example": 0
},
"KEY_VALUE_STORE_READS": {
"type": "integer",
"example": 0
},
"KEY_VALUE_STORE_WRITES": {
"type": "integer",
"example": 1
},
"KEY_VALUE_STORE_LISTS": {
"type": "integer",
"example": 0
},
"REQUEST_QUEUE_READS": {
"type": "integer",
"example": 0
},
"REQUEST_QUEUE_WRITES": {
"type": "integer",
"example": 0
},
"DATA_TRANSFER_INTERNAL_GBYTES": {
"type": "integer",
"example": 0
},
"DATA_TRANSFER_EXTERNAL_GBYTES": {
"type": "integer",
"example": 0
},
"PROXY_RESIDENTIAL_TRANSFER_GBYTES": {
"type": "integer",
"example": 0
},
"PROXY_SERPS": {
"type": "integer",
"example": 0
}
}
},
"usageTotalUsd": {
"type": "number",
"example": 0.00005
},
"usageUsd": {
"type": "object",
"properties": {
"ACTOR_COMPUTE_UNITS": {
"type": "integer",
"example": 0
},
"DATASET_READS": {
"type": "integer",
"example": 0
},
"DATASET_WRITES": {
"type": "integer",
"example": 0
},
"KEY_VALUE_STORE_READS": {
"type": "integer",
"example": 0
},
"KEY_VALUE_STORE_WRITES": {
"type": "number",
"example": 0.00005
},
"KEY_VALUE_STORE_LISTS": {
"type": "integer",
"example": 0
},
"REQUEST_QUEUE_READS": {
"type": "integer",
"example": 0
},
"REQUEST_QUEUE_WRITES": {
"type": "integer",
"example": 0
},
"DATA_TRANSFER_INTERNAL_GBYTES": {
"type": "integer",
"example": 0
},
"DATA_TRANSFER_EXTERNAL_GBYTES": {
"type": "integer",
"example": 0
},
"PROXY_RESIDENTIAL_TRANSFER_GBYTES": {
"type": "integer",
"example": 0
},
"PROXY_SERPS": {
"type": "integer",
"example": 0
}
}
}
}
}
}
}
}
}
}
```