Update metadata for collection releases

collections/prefect-airbyte/blocks/v0.3.1.json

@@ -0,0 +1,190 @@
+{
+  "prefect-airbyte": {
+    "block_types": {
+      "airbyte-connection": {
+        "name": "Airbyte Connection",
+        "slug": "airbyte-connection",
+        "logo_url": "https://images.ctfassets.net/zscdif0zqppk/6gm7wsC7ANnKYQsm7oiSYz/aac1ad5e054d35d9e24af8d6ed3aed5f/59758427?h=250",
+        "documentation_url": "https://prefecthq.github.io/prefect-airbyte/connections/#prefect_airbyte.connections.AirbyteConnection",
+        "description": "A block representing an existing Airbyte connection. This block is part of the prefect-airbyte collection. Install prefect-airbyte with `pip install prefect-airbyte` to use this block.",
+        "code_example": "Load an existing `AirbyteConnection` block:\n```python\nfrom prefect_airbyte import AirbyteConnection\n\nairbyte_connection = AirbyteConnection.load(\"BLOCK_NAME\")\n```\n\nRun an Airbyte connection sync as a flow:\n```python\nfrom prefect import flow\nfrom prefect_airbyte import AirbyteConnection\nfrom prefect_airbyte.flows import run_connection_sync # this is a flow\n\nairbyte_connection = AirbyteConnection.load(\"BLOCK_NAME\")\n\n@flow\ndef airbyte_orchestrator():\n    run_connection_sync(airbyte_connection) # now it's a subflow\n```",
+        "block_schema": {
+          "checksum": "sha256:b0d1479644a23659067536d89a7254ec7ab05101e225db74de165b90cd3a1d73",
+          "fields": {
+            "title": "AirbyteConnection",
+            "description": "A block representing an existing Airbyte connection.",
+            "type": "object",
+            "properties": {
+              "airbyte_server": {
+                "title": "Airbyte Server",
+                "description": "AirbyteServer block representing the Airbyte instance where the Airbyte connection is defined.",
+                "allOf": [
+                  {
+                    "$ref": "#/definitions/AirbyteServer"
+                  }
+                ]
+              },
+              "connection_id": {
+                "title": "Connection Id",
+                "description": "UUID of the Airbyte Connection to trigger.",
+                "type": "string",
+                "format": "uuid"
+              },
+              "poll_interval_s": {
+                "title": "Poll Interval S",
+                "description": "Time in seconds between status checks of the Airbyte sync job.",
+                "default": 15,
+                "type": "integer"
+              },
+              "status_updates": {
+                "title": "Status Updates",
+                "description": "Whether to log job status on each poll of the Airbyte sync job.",
+                "default": false,
+                "type": "boolean"
+              },
+              "timeout": {
+                "title": "Timeout",
+                "description": "Timeout in seconds for requests made by httpx.AsyncClient.",
+                "default": 5,
+                "type": "integer"
+              }
+            },
+            "required": [
+              "airbyte_server",
+              "connection_id"
+            ],
+            "block_type_slug": "airbyte-connection",
+            "secret_fields": [
+              "airbyte_server.password"
+            ],
+            "block_schema_references": {
+              "airbyte_server": {
+                "block_type_slug": "airbyte-server",
+                "block_schema_checksum": "sha256:f0bc49c549405ef3e753b3cc0a81e0e13b1b036acfab571c76f4d198c4bb842a"
+              }
+            },
+            "definitions": {
+              "AirbyteServer": {
+                "title": "AirbyteServer",
+                "description": "A block representing an Airbyte server for generating `AirbyteClient` instances.",
+                "type": "object",
+                "properties": {
+                  "username": {
+                    "title": "Username",
+                    "description": "Username to authenticate with Airbyte API.",
+                    "default": "airbyte",
+                    "type": "string"
+                  },
+                  "password": {
+                    "title": "Password",
+                    "description": "Password to authenticate with Airbyte API.",
+                    "default": "**********",
+                    "type": "string",
+                    "writeOnly": true,
+                    "format": "password"
+                  },
+                  "server_host": {
+                    "title": "Server Host",
+                    "description": "Host address of Airbyte server.",
+                    "default": "localhost",
+                    "example": "127.0.0.1",
+                    "type": "string"
+                  },
+                  "server_port": {
+                    "title": "Server Port",
+                    "description": "Port number of Airbyte server.",
+                    "default": 8000,
+                    "type": "integer"
+                  },
+                  "api_version": {
+                    "title": "API Version",
+                    "description": "Airbyte API version to use.",
+                    "default": "v1",
+                    "type": "string"
+                  },
+                  "use_ssl": {
+                    "title": "Use SSL",
+                    "description": "Whether to use SSL when connecting to Airbyte server.",
+                    "default": false,
+                    "type": "boolean"
+                  }
+                },
+                "block_type_slug": "airbyte-server",
+                "secret_fields": [
+                  "password"
+                ],
+                "block_schema_references": {}
+              }
+            }
+          },
+          "capabilities": [],
+          "version": "0.3.1"
+        }
+      },
+      "airbyte-server": {
+        "name": "Airbyte Server",
+        "slug": "airbyte-server",
+        "logo_url": "https://images.ctfassets.net/zscdif0zqppk/6gm7wsC7ANnKYQsm7oiSYz/aac1ad5e054d35d9e24af8d6ed3aed5f/59758427?h=250",
+        "documentation_url": "https://prefecthq.github.io/prefect-airbyte/server/#prefect_airbyte.server.AirbyteServer",
+        "description": "A block representing an Airbyte server for generating `AirbyteClient` instances. This block is part of the prefect-airbyte collection. Install prefect-airbyte with `pip install prefect-airbyte` to use this block.",
+        "code_example": "```python\nfrom prefect_airbyte.server import AirbyteServer\n\nserver = AirbyteServer.load(\"BLOCK_NAME\")\n```",
+        "block_schema": {
+          "checksum": "sha256:f0bc49c549405ef3e753b3cc0a81e0e13b1b036acfab571c76f4d198c4bb842a",
+          "fields": {
+            "title": "AirbyteServer",
+            "description": "A block representing an Airbyte server for generating `AirbyteClient` instances.",
+            "type": "object",
+            "properties": {
+              "username": {
+                "title": "Username",
+                "description": "Username to authenticate with Airbyte API.",
+                "default": "airbyte",
+                "type": "string"
+              },
+              "password": {
+                "title": "Password",
+                "description": "Password to authenticate with Airbyte API.",
+                "default": "**********",
+                "type": "string",
+                "writeOnly": true,
+                "format": "password"
+              },
+              "server_host": {
+                "title": "Server Host",
+                "description": "Host address of Airbyte server.",
+                "default": "localhost",
+                "example": "127.0.0.1",
+                "type": "string"
+              },
+              "server_port": {
+                "title": "Server Port",
+                "description": "Port number of Airbyte server.",
+                "default": 8000,
+                "type": "integer"
+              },
+              "api_version": {
+                "title": "API Version",
+                "description": "Airbyte API version to use.",
+                "default": "v1",
+                "type": "string"
+              },
+              "use_ssl": {
+                "title": "Use SSL",
+                "description": "Whether to use SSL when connecting to Airbyte server.",
+                "default": false,
+                "type": "boolean"
+              }
+            },
+            "block_type_slug": "airbyte-server",
+            "secret_fields": [
+              "password"
+            ],
+            "block_schema_references": {}
+          },
+          "capabilities": [],
+          "version": "0.3.1"
+        }
+      }
+    }
+  }
+}

collections/prefect-airbyte/flows/v0.3.1.json

@@ -0,0 +1,147 @@
+{
+  "prefect-airbyte": {
+    "run_connection_sync": {
+      "description": {
+        "summary": "A flow that triggers a sync of an Airbyte connection and waits for it to complete.",
+        "returns": "`AirbyteSyncResult`: Model containing metadata for the `AirbyteSync`.",
+        "examples": [
+          "Define a flow that runs an Airbyte connection sync:\n```python\nfrom prefect import flow\nfrom prefect_airbyte.server import AirbyteServer\nfrom prefect_airbyte.connections import AirbyteConnection\nfrom prefect_airbyte.flows import run_connection_sync\n\nairbyte_server = AirbyteServer(\n    server_host=\"localhost\",\n    server_port=8000\n)\n\nconnection = AirbyteConnection(\n    airbyte_server=airbyte_server,\n    connection_id=\"<YOUR-AIRBYTE-CONNECTION-UUID>\"\n)\n\n@flow\ndef airbyte_sync_flow():\n    # do some things\n\n    airbyte_sync_result = run_connection_sync(\n        airbyte_connection=connection\n    )\n    print(airbyte_sync_result.records_synced)\n\n    # do some other things, like trigger DBT based on number of new raw records\n```"
+        ]
+      },
+      "documentation_url": "https://prefecthq.github.io/prefect-airbyte/flows/#prefect_airbyte.flows.run_connection_sync",
+      "entrypoint": "prefect_airbyte/flows.py:run_connection_sync",
+      "install_command": "pip install prefect-airbyte",
+      "logo_url": "https://cdn.sanity.io/images/3ugk85nk/production/7f50097d1915fe75b0ee84c951c742a83d3c53cb-250x250.png",
+      "name": "run-connection-sync",
+      "parameters": {
+        "title": "Parameters",
+        "type": "object",
+        "properties": {
+          "airbyte_connection": {
+            "title": "airbyte_connection",
+            "description": "`AirbyteConnection` representing the Airbyte connection to\ntrigger and wait for completion of.",
+            "position": 0,
+            "allOf": [
+              {
+                "$ref": "#/definitions/AirbyteConnection"
+              }
+            ]
+          }
+        },
+        "required": [
+          "airbyte_connection"
+        ],
+        "definitions": {
+          "AirbyteServer": {
+            "title": "AirbyteServer",
+            "description": "A block representing an Airbyte server for generating `AirbyteClient` instances.",
+            "type": "object",
+            "properties": {
+              "username": {
+                "title": "Username",
+                "description": "Username to authenticate with Airbyte API.",
+                "default": "airbyte",
+                "type": "string"
+              },
+              "password": {
+                "title": "Password",
+                "description": "Password to authenticate with Airbyte API.",
+                "default": "**********",
+                "type": "string",
+                "writeOnly": true,
+                "format": "password"
+              },
+              "server_host": {
+                "title": "Server Host",
+                "description": "Host address of Airbyte server.",
+                "default": "localhost",
+                "example": "127.0.0.1",
+                "type": "string"
+              },
+              "server_port": {
+                "title": "Server Port",
+                "description": "Port number of Airbyte server.",
+                "default": 8000,
+                "type": "integer"
+              },
+              "api_version": {
+                "title": "API Version",
+                "description": "Airbyte API version to use.",
+                "default": "v1",
+                "type": "string"
+              },
+              "use_ssl": {
+                "title": "Use SSL",
+                "description": "Whether to use SSL when connecting to Airbyte server.",
+                "default": false,
+                "type": "boolean"
+              }
+            },
+            "block_type_slug": "airbyte-server",
+            "secret_fields": [
+              "password"
+            ],
+            "block_schema_references": {}
+          },
+          "AirbyteConnection": {
+            "title": "AirbyteConnection",
+            "description": "A block representing an existing Airbyte connection.",
+            "type": "object",
+            "properties": {
+              "airbyte_server": {
+                "title": "Airbyte Server",
+                "description": "AirbyteServer block representing the Airbyte instance where the Airbyte connection is defined.",
+                "allOf": [
+                  {
+                    "$ref": "#/definitions/AirbyteServer"
+                  }
+                ]
+              },
+              "connection_id": {
+                "title": "Connection Id",
+                "description": "UUID of the Airbyte Connection to trigger.",
+                "type": "string",
+                "format": "uuid"
+              },
+              "poll_interval_s": {
+                "title": "Poll Interval S",
+                "description": "Time in seconds between status checks of the Airbyte sync job.",
+                "default": 15,
+                "type": "integer"
+              },
+              "status_updates": {
+                "title": "Status Updates",
+                "description": "Whether to log job status on each poll of the Airbyte sync job.",
+                "default": false,
+                "type": "boolean"
+              },
+              "timeout": {
+                "title": "Timeout",
+                "description": "Timeout in seconds for requests made by httpx.AsyncClient.",
+                "default": 5,
+                "type": "integer"
+              }
+            },
+            "required": [
+              "airbyte_server",
+              "connection_id"
+            ],
+            "block_type_slug": "airbyte-connection",
+            "secret_fields": [
+              "airbyte_server.password"
+            ],
+            "block_schema_references": {
+              "airbyte_server": {
+                "block_type_slug": "airbyte-server",
+                "block_schema_checksum": "sha256:f0bc49c549405ef3e753b3cc0a81e0e13b1b036acfab571c76f4d198c4bb842a"
+              }
+            }
+          }
+        }
+      },
+      "path_containing_flow": "prefect_airbyte/flows.py",
+      "repo_url": "https://github.com/PrefectHQ/prefect-airbyte",
+      "slug": "run_connection_sync"
+    }
+  }
+}

collections/prefect-airbyte/workers/v0.3.1.json

@@ -0,0 +1,3 @@
+{
+  "prefect-airbyte": {}
+}