Update a bundle - Astronomer

POST

organizations

{organizationId}

deployments

{deploymentId}

bundles

{bundleId}

Update a bundle

curl --request POST \
  --url https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId} \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "dagBundleIds": [
    "<string>"
  ],
  "description": "Finance team Dags"
}
'

import requests

url = "https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}"

payload = {
    "dagBundleIds": ["<string>"],
    "description": "Finance team Dags"
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

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

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({dagBundleIds: ['<string>'], description: 'Finance team Dags'})
};

fetch('https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'dagBundleIds' => [
        '<string>'
    ],
    'description' => 'Finance team Dags'
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}"

	payload := strings.NewReader("{\n  \"dagBundleIds\": [\n    \"<string>\"\n  ],\n  \"description\": \"Finance team Dags\"\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"dagBundleIds\": [\n    \"<string>\"\n  ],\n  \"description\": \"Finance team Dags\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"dagBundleIds\": [\n    \"<string>\"\n  ],\n  \"description\": \"Finance team Dags\"\n}"

response = http.request(request)
puts response.read_body

{
  "createdAt": "2022-11-22T04:37:12Z",
  "deletionIsPending": true,
  "id": "clvetru2w000201mowqwua63n",
  "isDagBundle": true,
  "isDefault": true,
  "type": "DEPLOY",
  "updatedAt": "2022-11-22T04:37:12Z",
  "currentVersion": "<string>",
  "dagBundleIds": [
    "<string>"
  ],
  "description": "Finance team Dags",
  "desiredVersion": "<string>",
  "lastDeployId": "clvetru2w000201mowqwua63n",
  "name": "finance",
  "nonDagBundleType": "dbt",
  "nonDagMountPath": "/usr/local/airflow/dbt"
}

{
  "message": "<string>",
  "requestId": "<string>",
  "statusCode": 500,
  "fieldErrors": [
    {
      "code": "<string>",
      "field": "<string>",
      "message": "<string>"
    }
  ]
}

{
  "message": "<string>",
  "requestId": "<string>",
  "statusCode": 500,
  "fieldErrors": [
    {
      "code": "<string>",
      "field": "<string>",
      "message": "<string>"
    }
  ]
}

{
  "message": "<string>",
  "requestId": "<string>",
  "statusCode": 500,
  "fieldErrors": [
    {
      "code": "<string>",
      "field": "<string>",
      "message": "<string>"
    }
  ]
}

{
  "message": "<string>",
  "requestId": "<string>",
  "statusCode": 500,
  "fieldErrors": [
    {
      "code": "<string>",
      "field": "<string>",
      "message": "<string>"
    }
  ]
}

{
  "message": "<string>",
  "requestId": "<string>",
  "statusCode": 500,
  "fieldErrors": [
    {
      "code": "<string>",
      "field": "<string>",
      "message": "<string>"
    }
  ]
}

Authorizations

Authorization

string

header

required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Path Parameters

organizationId

string

required

The ID of the Organization to which the Deployment belongs.

deploymentId

string

required

The Deployment's ID.

bundleId

string

required

The bundle's ID.

Body

application/json

The request body for updating a bundle.

dagBundleIds

string[]

The IDs of the Dag bundles that Astro serves the bundle alongside, replacing the current set. Only valid for non-Dag bundles.

Required array length: 1 - 1000 elements

description

string

The bundle's description.

Maximum string length: 500

Example:

"Finance team Dags"

Response

createdAt

string<date-time>

required

The time when the bundle was created in UTC, formatted as YYYY-MM-DDTHH:MM:SSZ.

Example:

"2022-11-22T04:37:12Z"

deletionIsPending

boolean

required

Whether the bundle has been deleted but is still on the Deployment.

string

required

The bundle's ID.

Example:

"clvetru2w000201mowqwua63n"

isDagBundle

boolean

required

Whether the bundle contains Dags. A non-Dag bundle contains other files, such as a dbt project.

isDefault

boolean

required

Whether the bundle is the Deployment's default Dag bundle.

type

enum<string>

required

The bundle's type. DEPLOY for a bundle written by a deploy.

Available options:

DEPLOY

Example:

"DEPLOY"

updatedAt

string<date-time>

required

The time when the bundle was last updated in UTC, formatted as YYYY-MM-DDTHH:MM:SSZ.

Example:

"2022-11-22T04:37:12Z"

currentVersion

string

The bundle version most recently reported as running on the Deployment.

dagBundleIds

string[]

The IDs of the Dag bundles that Astro serves the bundle alongside. Appears only for non-Dag bundles.

description

string

The bundle's description.

Example:

"Finance team Dags"

desiredVersion

string

The bundle version the Deployment is configured to run.

lastDeployId

string

The ID of the deploy that last changed the bundle. Appears only after the bundle's first deploy.

Example:

"clvetru2w000201mowqwua63n"

name

string

The bundle's name. Appears only for Dag bundles.

Example:

"finance"

nonDagBundleType

string

The kind of files the bundle contains. Appears only for non-Dag bundles.

Example:

"dbt"

nonDagMountPath

string

The path where Astro mounts the bundle on the Airflow component pods. Appears only for non-Dag bundles.

Example:

"/usr/local/airflow/dbt"

⌘I

Update a bundle

curl --request POST \
  --url https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId} \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "dagBundleIds": [
    "<string>"
  ],
  "description": "Finance team Dags"
}
'

import requests

url = "https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}"

payload = {
    "dagBundleIds": ["<string>"],
    "description": "Finance team Dags"
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

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

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({dagBundleIds: ['<string>'], description: 'Finance team Dags'})
};

fetch('https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'dagBundleIds' => [
        '<string>'
    ],
    'description' => 'Finance team Dags'
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}"

	payload := strings.NewReader("{\n  \"dagBundleIds\": [\n    \"<string>\"\n  ],\n  \"description\": \"Finance team Dags\"\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"dagBundleIds\": [\n    \"<string>\"\n  ],\n  \"description\": \"Finance team Dags\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"dagBundleIds\": [\n    \"<string>\"\n  ],\n  \"description\": \"Finance team Dags\"\n}"

response = http.request(request)
puts response.read_body

{
  "createdAt": "2022-11-22T04:37:12Z",
  "deletionIsPending": true,
  "id": "clvetru2w000201mowqwua63n",
  "isDagBundle": true,
  "isDefault": true,
  "type": "DEPLOY",
  "updatedAt": "2022-11-22T04:37:12Z",
  "currentVersion": "<string>",
  "dagBundleIds": [
    "<string>"
  ],
  "description": "Finance team Dags",
  "desiredVersion": "<string>",
  "lastDeployId": "clvetru2w000201mowqwua63n",
  "name": "finance",
  "nonDagBundleType": "dbt",
  "nonDagMountPath": "/usr/local/airflow/dbt"
}

{
  "message": "<string>",
  "requestId": "<string>",
  "statusCode": 500,
  "fieldErrors": [
    {
      "code": "<string>",
      "field": "<string>",
      "message": "<string>"
    }
  ]
}

{
  "message": "<string>",
  "requestId": "<string>",
  "statusCode": 500,
  "fieldErrors": [
    {
      "code": "<string>",
      "field": "<string>",
      "message": "<string>"
    }
  ]
}

{
  "message": "<string>",
  "requestId": "<string>",
  "statusCode": 500,
  "fieldErrors": [
    {
      "code": "<string>",
      "field": "<string>",
      "message": "<string>"
    }
  ]
}

{
  "message": "<string>",
  "requestId": "<string>",
  "statusCode": 500,
  "fieldErrors": [
    {
      "code": "<string>",
      "field": "<string>",
      "message": "<string>"
    }
  ]
}

{
  "message": "<string>",
  "requestId": "<string>",
  "statusCode": 500,
  "fieldErrors": [
    {
      "code": "<string>",
      "field": "<string>",
      "message": "<string>"
    }
  ]
}