Jobs

import time
from nimble_python import Nimble

nimble = Nimble(api_key="YOUR-API-KEY")

# 1. Create a job — bind a template to inputs, a destination, and a schedule
job = nimble.jobs.create(
    name="daily_amazon_top_skus",
    extract_template_name="amazon_pdp",
    schedule={"cron": "0 7 * * *", "enabled": True},
    inputs={
        "type": "inline",
        "data": [{"asin": "B08N5WRWNW"}, {"asin": "B0DLKFK6LR"}],
    },
    destination={
        "type": "s3",
        "path": "s3://my-bucket/amazon-skus/",
        "format": "parquet",
    },
)

# 2. Trigger a run now (on top of any schedule)
run = nimble.jobs.runs.create(job.id)

# 3. Poll until the run reaches a terminal state
status = run.status
while status in ("PENDING", "RUNNING"):
    time.sleep(10)
    status = nimble.jobs.runs.get(run.id).status

# 4. Download the assembled results
artifacts = nimble.jobs.runs.artifacts.list(run.id)
download = nimble.jobs.runs.artifacts.download_url(
    int(artifacts.items[0].id),
    run_id=run.id,
)
print(download.url)

import Nimble from "@nimble-way/nimble-js";

const nimble = new Nimble({ apiKey: "YOUR-API-KEY" });

// 1. Create a job — bind a template to inputs, a destination, and a schedule
const job = await nimble.jobs.create({
  name: "daily_amazon_top_skus",
  extract_template_name: "amazon_pdp",
  schedule: { cron: "0 7 * * *", enabled: true },
  inputs: {
    type: "inline",
    data: [{ asin: "B08N5WRWNW" }, { asin: "B0DLKFK6LR" }],
  },
  destination: {
    type: "s3",
    path: "s3://my-bucket/amazon-skus/",
    format: "parquet",
  },
});

// 2. Trigger a run now (on top of any schedule)
const run = await nimble.jobs.runs.create(job.id);

// 3. Poll until the run reaches a terminal state
let status: string = run.status;
while (status === "PENDING" || status === "RUNNING") {
  await new Promise((r) => setTimeout(r, 10000));
  status = (await nimble.jobs.runs.get(run.id)).status;
}

// 4. Download the assembled results
const artifacts = await nimble.jobs.runs.artifacts.list(run.id);
const download = await nimble.jobs.runs.artifacts.downloadURL(
  Number(artifacts.items[0].id),
  { run_id: run.id },
);
console.log(download.url);

package main

import (
    "context"
    "fmt"
    "strconv"
    "time"

    nimble "github.com/Nimbleway/nimble-go"
    "github.com/Nimbleway/nimble-go/option"
)

func main() {
    client := nimble.NewClient(option.WithAPIKey("YOUR-API-KEY"))
    ctx := context.Background()

    // 1. Create a job — bind a template to inputs, a destination, and a schedule
    job, err := client.Jobs.New(ctx, nimble.JobNewParams{
        Name:                "daily_amazon_top_skus",
        ExtractTemplateName: "amazon_pdp",
        Schedule:            nimble.JobNewParamsSchedule{Cron: "0 7 * * *", Enabled: true},
        Inputs: nimble.JobNewParamsInputs{
            Type: "inline",
            Data: []map[string]any{{"asin": "B08N5WRWNW"}, {"asin": "B0DLKFK6LR"}},
        },
        Destination: nimble.JobNewParamsDestination{
            Type:   "s3",
            Path:   "s3://my-bucket/amazon-skus/",
            Format: "parquet",
        },
    })
    if err != nil {
        panic(err)
    }

    // 2. Trigger a run now (on top of any schedule)
    run, err := client.Jobs.Runs.New(ctx, job.ID)
    if err != nil {
        panic(err)
    }

    // 3. Poll until the run reaches a terminal state
    status := string(run.Status)
    for status == "PENDING" || status == "RUNNING" {
        time.Sleep(10 * time.Second)
        polled, err := client.Jobs.Runs.Get(ctx, run.ID)
        if err != nil {
            panic(err)
        }
        status = string(polled.Status)
    }

    // 4. Download the assembled results
    artifacts, err := client.Jobs.Runs.Artifacts.List(ctx, run.ID)
    if err != nil {
        panic(err)
    }
    artifactID, _ := strconv.ParseInt(artifacts.Items[0].ID, 10, 64)
    download, err := client.Jobs.Runs.Artifacts.DownloadURL(ctx, artifactID,
        nimble.JobRunArtifactDownloadURLParams{RunID: run.ID})
    if err != nil {
        panic(err)
    }
    fmt.Println(download.URL)
}

# 1. Create a job
JOB_ID=$(nimble jobs create   --name daily_amazon_top_skus   --extract-template-name amazon_pdp   --schedule '{cron: "0 7 * * *", enabled: true}'   --inputs '{type: inline, data: [{asin: B08N5WRWNW}, {asin: B0DLKFK6LR}]}'   --destination '{type: s3, path: "s3://my-bucket/amazon-skus/", format: parquet}'   | jq -r .id)

# 2. Trigger a run now (on top of any schedule)
RUN_ID=$(nimble jobs:runs create --job-id "$JOB_ID" | jq -r .id)

# 3. Poll until the run reaches a terminal state
nimble jobs:runs get --run-id "$RUN_ID"

# 4. Download the assembled results
nimble jobs:runs:artifacts list --run-id "$RUN_ID"
nimble jobs:runs:artifacts download-url --run-id "$RUN_ID" --artifact-id 7

# 1. Create a job
curl -X POST 'https://sdk.nimbleway.com/v2/jobs' \
--header 'Authorization: Bearer YOUR-API-KEY' \
--header 'Content-Type: application/json' \
--data-raw '{
    "name": "daily_amazon_top_skus",
    "extract_template_name": "amazon_pdp",
    "schedule": {"cron": "0 7 * * *", "enabled": true},
    "inputs": {
      "type": "inline",
      "data": [{"asin": "B08N5WRWNW"}, {"asin": "B0DLKFK6LR"}]
    },
    "destination": {
      "type": "s3",
      "path": "s3://my-bucket/amazon-skus/",
      "format": "parquet"
    }
}'

# 2. Trigger a run (returns a run with id "run_<n>")
curl -X POST 'https://sdk.nimbleway.com/v2/jobs/job_42/runs' \
--header 'Authorization: Bearer YOUR-API-KEY'

# 3. Poll the run until status is SUCCESS
curl -X GET 'https://sdk.nimbleway.com/v2/jobs/runs/run_1204' \
--header 'Authorization: Bearer YOUR-API-KEY'

# 4. Get a presigned download URL for an artifact
curl -X GET 'https://sdk.nimbleway.com/v2/jobs/runs/run_1204/artifacts/7/download-url' \
--header 'Authorization: Bearer YOUR-API-KEY'