Get a bundle - Astronomer

GET

organizations

{organizationId}

deployments

{deploymentId}

bundles

{bundleId}

Get a bundle

curl --request GET \
  --url https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId} \
  --header 'Authorization: Bearer <token>'

import requests

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

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

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 => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

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

curl_close($curl);

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

package main

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

func main() {

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

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

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

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

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}")
  .header("Authorization", "Bearer <token>")
  .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::Get.new(url)
request["Authorization"] = 'Bearer <token>'

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.

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

Get a bundle

curl --request GET \
  --url https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId} \
  --header 'Authorization: Bearer <token>'

import requests

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

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

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 => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

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

curl_close($curl);

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

package main

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

func main() {

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

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

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

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

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://api.astronomer.io/v1/organizations/{organizationId}/deployments/{deploymentId}/bundles/{bundleId}")
  .header("Authorization", "Bearer <token>")
  .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::Get.new(url)
request["Authorization"] = 'Bearer <token>'

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>"
    }
  ]
}