cleanups

Author: razvan

extra/crds.yaml

@@ -12664,102 +12664,3 @@ spec:
     storage: false
     subresources:
       status: {}
----
-apiVersion: apiextensions.k8s.io/v1
-kind: CustomResourceDefinition
-metadata:
-  name: openlineageconnections.openlineage.stackable.tech
-spec:
-  group: openlineage.stackable.tech
-  names:
-    categories: []
-    kind: OpenLineageConnection
-    plural: openlineageconnections
-    shortNames: []
-    singular: openlineageconnection
-  scope: Namespaced
-  versions:
-  - additionalPrinterColumns: []
-    name: v1alpha1
-    schema:
-      openAPIV3Schema:
-        description: A reusable definition of a connection to an OpenLineage backend.
-        properties:
-          spec:
-            description: |-
-              OpenLineage connection definition as a resource.
-              Learn more about [OpenLineage](https://openlineage.io/).
-            properties:
-              credentialsSecretName:
-                description: |-
-                  Name of a Secret containing the API key used to authenticate against the OpenLineage
-                  backend. The API key must be stored under the key `apiKey`. The Secret must be located in
-                  the same namespace as the workload using this connection. If not specified, no
-                  authentication is used.
-                nullable: true
-                type: string
-              host:
-                description: 'Host of the OpenLineage backend without any protocol or port. For example: `marquez`.'
-                type: string
-              port:
-                description: 'Port the OpenLineage backend listens on. For example: `5000`.'
-                format: uint16
-                maximum: 65535.0
-                minimum: 0.0
-                type: integer
-              tls:
-                description: Use a TLS connection. If not specified no TLS will be used.
-                nullable: true
-                properties:
-                  verification:
-                    description: The verification method used to verify the certificates of the server and/or the client.
-                    oneOf:
-                    - required:
-                      - none
-                    - required:
-                      - server
-                    properties:
-                      none:
-                        description: Use TLS but don't verify certificates.
-                        type: object
-                      server:
-                        description: Use TLS and a CA certificate to verify the server.
-                        properties:
-                          caCert:
-                            description: CA cert to verify the server.
-                            oneOf:
-                            - required:
-                              - webPki
-                            - required:
-                              - secretClass
-                            properties:
-                              secretClass:
-                                description: |-
-                                  Name of the [SecretClass](https://docs.stackable.tech/home/nightly/secret-operator/secretclass) which will provide the CA certificate.
-                                  Note that a SecretClass does not need to have a key but can also work with just a CA certificate,
-                                  so if you got provided with a CA cert but don't have access to the key you can still use this method.
-                                type: string
-                              webPki:
-                                description: |-
-                                  Use TLS and the CA certificates trusted by the common web browsers to verify the server.
-                                  This can be useful when you e.g. use public AWS S3 or other public available services.
-                                type: object
-                            type: object
-                        required:
-                        - caCert
-                        type: object
-                    type: object
-                required:
-                - verification
-                type: object
-            required:
-            - host
-            - port
-            type: object
-        required:
-        - spec
-        title: OpenLineageConnection
-        type: object
-    served: true
-    storage: true
-    subresources: {}

rust/operator-binary/src/main.rs

@@ -10,10 +10,7 @@ use futures::{FutureExt, StreamExt, TryFutureExt};
 use stackable_operator::{
     YamlSchema,
     cli::{Command, RunArguments},
-    crd::{
-        authentication::core as auth_core,
-        openlineage::{self, OpenLineageConnection, OpenLineageConnectionVersion},
-    },
+    crd::{authentication::core as auth_core, openlineage},
     eos::EndOfSupportChecker,
     k8s_openapi::api::{
         apps::v1::StatefulSet,
@@ -66,8 +63,6 @@ async fn main() -> anyhow::Result<()> {
         Command::Crd => {
             AirflowCluster::merged_crd(AirflowClusterVersion::V1Alpha2)?
                 .print_yaml_schema(built_info::PKG_VERSION, &SerializeOptions::default())?;
-            OpenLineageConnection::merged_crd(OpenLineageConnectionVersion::V1Alpha1)?
-                .print_yaml_schema(built_info::PKG_VERSION, &SerializeOptions::default())?;
         }
         Command::Run(RunArguments {
             watch_namespace,

rust/operator-binary/src/webhooks/conversion.rs

@@ -1,7 +1,6 @@
 use snafu::{ResultExt, Snafu};
 use stackable_operator::{
     cli::OperatorEnvironmentOptions,
-    crd::openlineage::{OpenLineageConnection, OpenLineageConnectionVersion},
     kube::{Client, core::crd::MergeError},
     webhook::{
         WebhookServer, WebhookServerError, WebhookServerOptions,
@@ -30,17 +29,10 @@ pub async fn create_webhook_server(
 ) -> Result<WebhookServer, Error> {
     // The conversion handlers are cast to fn pointers so both CRD entries share a single element
     // type (each `fn` item otherwise has its own unique type).
-    let crds_and_handlers = vec![
-        (
-            AirflowCluster::merged_crd(AirflowClusterVersion::V1Alpha2).context(MergeCrdSnafu)?,
-            AirflowCluster::try_convert as fn(ConversionReview) -> ConversionReview,
-        ),
-        (
-            OpenLineageConnection::merged_crd(OpenLineageConnectionVersion::V1Alpha1)
-                .context(MergeCrdSnafu)?,
-            OpenLineageConnection::try_convert as fn(ConversionReview) -> ConversionReview,
-        ),
-    ];
+    let crds_and_handlers = vec![(
+        AirflowCluster::merged_crd(AirflowClusterVersion::V1Alpha2).context(MergeCrdSnafu)?,
+        AirflowCluster::try_convert as fn(ConversionReview) -> ConversionReview,
+    )];
 
     let conversion_webhook_options = ConversionWebhookOptions {
         disable_crd_maintenance,