Logs stream (SSE) - fal

POST

/

serverless

/

logs

/

stream

Logs stream (SSE)

curl --request POST \
  --url https://api.fal.ai/v1/serverless/logs/stream \
  --header 'Authorization: <api-key>' \
  --header 'Content-Type: application/json' \
  --data '
[
  {
    "key": "fal_job_id",
    "value": "job_123"
  }
]
'

import requests

url = "https://api.fal.ai/v1/serverless/logs/stream"

payload = [
    {
        "key": "fal_job_id",
        "value": "job_123"
    }
]
headers = {
    "Authorization": "<api-key>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: '<api-key>', 'Content-Type': 'application/json'},
  body: JSON.stringify([{key: 'fal_job_id', value: 'job_123'}])
};

fetch('https://api.fal.ai/v1/serverless/logs/stream', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

{
  "error": {
    "type": "authorization_error",
    "message": "Authentication required"
  }
}

{
  "error": {
    "type": "rate_limited",
    "message": "Rate limit exceeded"
  }
}

{
  "error": {
    "type": "server_error",
    "message": "An unexpected error occurred"
  }
}

Authorizations

Authorization

string

header

required

Key on the READONLY preset, or any key whose permissions include the ones this API lists. Prefix it with "Key ", e.g. Authorization: Key YOUR_API_KEY

Query Parameters

start

Start date in ISO8601 format (e.g., '2025-01-01T00:00:00Z' or '2025-01-01'). Defaults to 24 hours ago.

Example:

"2025-01-01T00:00:00Z"

end

End date in ISO8601 format, exclusive (e.g., '2025-02-01T00:00:00Z' or '2025-02-01'). Data up to but not including this timestamp is returned. Defaults to current time.

Example:

"2025-02-01T00:00:00Z"

app_id

Filter by specific app ID(s) in '/' format (e.g. 'fal-ai/my-app'). Accepts 1-50 app IDs. Supports comma-separated values: ?app_id=fal-ai/foo,fal-ai/bar or array syntax: ?app_id=fal-ai/foo&app_id=fal-ai/bar

Example:

["fal-ai/my-app"]

revision

string

Filter by revision

Example:

"rev_abc123"

run_source

enum<string>

Filter by run source

Available options:

grpc-run,

grpc-register,

gateway,

cron

Example:

"grpc-run"

traceback

boolean | null

default:false

Include tracebacks

Example:

false

search

string

Free-text search

Example:

"error"

level

string

Minimum log level

Example:

"error"

job_id

string

Filter by job id

Example:

"job_123"

request_id

string

Filter by request id

Example:

"019e6d0a-e5be-7b82-b329-35ae64296902"

Body

application/json

key

string

required

Label key to filter

value

required

Filter value

condition_type

enum<string>

Condition type for label filtering

Available options:

equals,

in,

not_equals,

not_in

Response

SSE stream started

⌘I

Logs stream (SSE)

curl --request POST \
  --url https://api.fal.ai/v1/serverless/logs/stream \
  --header 'Authorization: <api-key>' \
  --header 'Content-Type: application/json' \
  --data '
[
  {
    "key": "fal_job_id",
    "value": "job_123"
  }
]
'

import requests

url = "https://api.fal.ai/v1/serverless/logs/stream"

payload = [
    {
        "key": "fal_job_id",
        "value": "job_123"
    }
]
headers = {
    "Authorization": "<api-key>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: '<api-key>', 'Content-Type': 'application/json'},
  body: JSON.stringify([{key: 'fal_job_id', value: 'job_123'}])
};

fetch('https://api.fal.ai/v1/serverless/logs/stream', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

{
  "error": {
    "type": "authorization_error",
    "message": "Authentication required"
  }
}

{
  "error": {
    "type": "rate_limited",
    "message": "Rate limit exceeded"
  }
}

{
  "error": {
    "type": "server_error",
    "message": "An unexpected error occurred"
  }
}