# US WARN Layoff Notice Aggregator & Delta Monitor (OR/TX API) (`malonestar/warn-layoff-aggregator`) Actor

Aggregate US state WARN Act layoff & closure notices into one normalized schema and track new / updated / removed deltas. Oregon & Texas live (keyless Socrata); CA/NY/WA/WI/IL/NJ scaffolded. For RevOps, recruiting, econ research and CRE. No API key.

- **URL**: https://apify.com/malonestar/warn-layoff-aggregator.md
- **Developed by:** [Kyle Maloney](https://apify.com/malonestar) (community)
- **Categories:** Lead generation, Developer tools, Agents
- **Stats:** 2 total users, 1 monthly users, 100.0% runs succeeded, 0 bookmarks
- **User rating**: No ratings yet

## Pricing

from $8.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.md):

```bash
npm install apify-client
```

In Python projects, use official [Python client library](https://docs.apify.com/api/client/python.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/platform/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

## US WARN Layoff Notice Aggregator & Delta Monitor

Aggregate **US state WARN Act layoff & plant-closure notices** into **one normalized
schema**, and get a **delta feed** of exactly what changed since your last run: **new**
notices, **updated** notices (employee count / effective date / type revised), and
**removed** notices.

Every state publishes WARN filings in a different shape (Socrata, CSV, HTML, Excel) with
different column names and layoff-type wording. This actor unifies them so you can monitor
layoffs across states from a single, stable dataset — **no logins, no API keys.**

### Who it's for
- **RevOps & recruiting / staffing** — catch fresh layoffs the day they're filed to source candidates or reach affected employers before competitors.
- **Economic & labor-market researchers** — build a clean cross-state layoff time series without hand-scraping each agency portal.
- **Commercial real estate (CRE) & site selection** — flag closures that free up facilities and shifts in regional employment.
- **Investors & risk / supply-chain teams** — track distress signals by company, county and sector.

### Coverage
| State | Source | Status |
|-------|--------|--------|
| **OR** Oregon | Socrata `data.oregon.gov` (`ijbz-jpx8`) | **Live** — fully wired |
| **TX** Texas | Socrata `data.texas.gov` (`8w53-c4f6`) | **Live** — fully wired (current calendar year) |
| CA California | EDD WARN report (HTML/Excel) | Coming later |
| NY New York | NY DOL WARN (HTML) | Coming later |
| WA Washington | ESD WARN (Excel) | Coming later |
| WI Wisconsin | DWD WARN (HTML) | Coming later |
| IL Illinois | DCEO WARN (HTML/PDF) | Coming later |
| NJ New Jersey | NJ DOL WARN (HTML) | Coming later |

Adding a state is a single config block (`{ state, format, domain, datasetId, map }`) in
`source.js`, so coverage expands without touching the core logic. States marked "coming
later" publish only HTML/Excel/PDF today; they are scaffolded config blocks and return no
data until a parser is wired.

### Example input — snapshot
```json
{
  "states": ["OR", "TX"],
  "mode": "snapshot",
  "sinceDate": "2026-01-01",
  "maxResults": 100000
}
````

### Example input — delta (scheduled monitoring)

```json
{
  "states": ["OR", "TX"],
  "mode": "delta",
  "priorKvKey": "warn_last_snapshot"
}
```

In delta mode with `priorKvKey`, the actor diffs against the snapshot stored under that key
**and** saves the current snapshot back to it — so a daily schedule emits only what changed.
Alternatively pass the prior records directly as `priorItems`.

### Output fields

`state`, `company`, `city`, `county`, `notice_date`, `effective_date`, `employees_affected`,
`layoff_type` (layoff/closure/relocation), `industry`, `region`, `notice_id`, `source_url`,
`retrieved_at`. Dates are normalized to `YYYY-MM-DD`.

In **delta** mode each row also carries `change_type` (`new` | `updated` | `removed`) plus
`old_*` / `new_*` for `employees_affected`, `effective_date` and `layoff_type`.

### Use as an MCP tool

This actor is callable by AI agents (Claude, Cursor, etc.) via **mcp.apify.com**. The clean,
field-level output schema makes it a good chainable tool: an agent can pull a state's WARN
notices, filter by company, county or headcount, and hand rows to an outreach, enrichment or
analysis step.

### FAQ

**How do I monitor for new layoff notices?** Run in `delta` mode on a schedule with a
`priorKvKey`; each run emits only new / updated / removed rows.

**Which states are live today?** Oregon and Texas are fully wired via their keyless Socrata
open-data APIs. California, New York, Washington, Wisconsin, Illinois and New Jersey are
scaffolded and coming in a later version (their filings are HTML/Excel/PDF only).

**What counts as an "updated" notice?** The employee count, effective date, or layoff type
changed versus the prior snapshot.

**Do I need an API key?** No. All sources are public and keyless.

**How is it billed?** Pay per result — one WARN notice (or one delta change row) = one
dataset item.

# Actor input Schema

## `states` (type: `array`):

Two-letter state codes to pull WARN notices for. Leave empty for all fully-wired sources (currently OR and TX). Available config blocks: OR, TX (live) and CA, NY, WA, WI, IL, NJ (scaffolded — HTML/Excel sources returning no data until wired in a later version).

## `mode` (type: `string`):

snapshot = emit the current normalized WARN notices. delta = compare against a prior snapshot and emit only change rows (new / updated / removed).

## `sinceDate` (type: `string`):

Optional lower bound (YYYY-MM-DD) on the notice date. When set, only notices on or after this date are fetched. Leave blank for all available notices.

## `priorItems` (type: `array`):

Delta mode: the prior run's unified notice items (the array of records this actor produced before). The diff is computed purely against these. Ignored in snapshot mode.

## `priorKvKey` (type: `string`):

Delta mode alternative to priorItems: a key in this actor's key-value store holding the prior snapshot. When set, the current snapshot is also SAVED under this key so scheduled runs diff automatically against the previous run.

## `maxResults` (type: `integer`):

Maximum number of WARN notices to fetch across all selected states.

## Actor input object example

```json
{
  "states": [
    "OR",
    "TX"
  ],
  "mode": "snapshot",
  "priorItems": [],
  "maxResults": 100000
}
```

# Actor output Schema

## `results` (type: `string`):

Normalized WARN notices in the default dataset.

# 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 '<YOUR_API_TOKEN>' with your token
const client = new ApifyClient({
    token: '<YOUR_API_TOKEN>',
});

// Prepare Actor input
const input = {
    "states": [
        "OR",
        "TX"
    ]
};

// Run the Actor and wait for it to finish
const run = await client.actor("malonestar/warn-layoff-aggregator").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 '<YOUR_API_TOKEN>' with your token.
client = ApifyClient("<YOUR_API_TOKEN>")

# Prepare the Actor input
run_input = { "states": [
        "OR",
        "TX",
    ] }

# Run the Actor and wait for it to finish
run = client.actor("malonestar/warn-layoff-aggregator").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 '{
  "states": [
    "OR",
    "TX"
  ]
}' |
apify call malonestar/warn-layoff-aggregator --silent --output-dataset

```

## MCP server setup

```json
{
    "mcpServers": {
        "apify": {
            "command": "npx",
            "args": [
                "mcp-remote",
                "https://mcp.apify.com/?tools=malonestar/warn-layoff-aggregator",
                "--header",
                "Authorization: Bearer <YOUR_API_TOKEN>"
            ]
        }
    }
}

```

## OpenAPI specification

```json
{
    "openapi": "3.0.1",
    "info": {
        "title": "US WARN Layoff Notice Aggregator & Delta Monitor (OR/TX API)",
        "description": "Aggregate US state WARN Act layoff & closure notices into one normalized schema and track new / updated / removed deltas. Oregon & Texas live (keyless Socrata); CA/NY/WA/WI/IL/NJ scaffolded. For RevOps, recruiting, econ research and CRE. No API key.",
        "version": "1.0",
        "x-build-id": "PT862691f8pqNgWKQ"
    },
    "servers": [
        {
            "url": "https://api.apify.com/v2"
        }
    ],
    "paths": {
        "/acts/malonestar~warn-layoff-aggregator/run-sync-get-dataset-items": {
            "post": {
                "operationId": "run-sync-get-dataset-items-malonestar-warn-layoff-aggregator",
                "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/malonestar~warn-layoff-aggregator/runs": {
            "post": {
                "operationId": "runs-sync-malonestar-warn-layoff-aggregator",
                "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/malonestar~warn-layoff-aggregator/run-sync": {
            "post": {
                "operationId": "run-sync-malonestar-warn-layoff-aggregator",
                "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",
                "properties": {
                    "states": {
                        "title": "States",
                        "type": "array",
                        "description": "Two-letter state codes to pull WARN notices for. Leave empty for all fully-wired sources (currently OR and TX). Available config blocks: OR, TX (live) and CA, NY, WA, WI, IL, NJ (scaffolded — HTML/Excel sources returning no data until wired in a later version).",
                        "default": [],
                        "items": {
                            "type": "string"
                        }
                    },
                    "mode": {
                        "title": "Mode",
                        "enum": [
                            "snapshot",
                            "delta"
                        ],
                        "type": "string",
                        "description": "snapshot = emit the current normalized WARN notices. delta = compare against a prior snapshot and emit only change rows (new / updated / removed).",
                        "default": "snapshot"
                    },
                    "sinceDate": {
                        "title": "Since date",
                        "type": "string",
                        "description": "Optional lower bound (YYYY-MM-DD) on the notice date. When set, only notices on or after this date are fetched. Leave blank for all available notices."
                    },
                    "priorItems": {
                        "title": "Prior items (delta mode)",
                        "type": "array",
                        "description": "Delta mode: the prior run's unified notice items (the array of records this actor produced before). The diff is computed purely against these. Ignored in snapshot mode.",
                        "default": []
                    },
                    "priorKvKey": {
                        "title": "Prior snapshot key (delta mode)",
                        "type": "string",
                        "description": "Delta mode alternative to priorItems: a key in this actor's key-value store holding the prior snapshot. When set, the current snapshot is also SAVED under this key so scheduled runs diff automatically against the previous run."
                    },
                    "maxResults": {
                        "title": "Max results",
                        "minimum": 1,
                        "maximum": 500000,
                        "type": "integer",
                        "description": "Maximum number of WARN notices to fetch across all selected states.",
                        "default": 100000
                    }
                }
            },
            "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
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }
    }
}
```