Added sync and async integration tests to fail condition (#337)

Co-authored-by: igor chvyrov <igorchvyrov@igors-MacBook-Pro.local>

Author: IgorChvyrov-sm

.github/workflows/pull_request.yml

@@ -123,5 +123,5 @@ jobs:
           file: ${{ env.COVERAGE_FILE }}
 
       - name: Check test results
-        if: steps.unit_tests.outcome == 'failure' || steps.bc_tests.outcome == 'failure' || steps.serdeser_tests.outcome == 'failure'
+        if: steps.unit_tests.outcome == 'failure' || steps.bc_tests.outcome == 'failure' || steps.serdeser_tests.outcome == 'failure' || steps.integration_tests.outcome == 'failure' || steps.asyncio_integration_tests.outcome == 'failure'
         run: exit 1

poetry.lock

@@ -37,7 +37,7 @@ python-dateutil = "^2.8.2"
 pydantic = "2.11.7"
 aiohttp = "3.12.15"
 aiohttp-retry = "2.9.1"
-httpx = "^0.28.1"
+httpx = {extras = ["http2"], version = "^0.28.1"}
 
 [tool.poetry.group.dev.dependencies]
 pylint = ">=2.17.5"

pyproject.toml

@@ -2,6 +2,7 @@
 
 from typing import Any, Dict, List, Optional
 
+from pydantic import field_validator
 from typing_extensions import Self
 
 from conductor.asyncio_client.http.models import Integration
@@ -12,6 +13,30 @@ class IntegrationAdapter(Integration):
     configuration: Optional[Dict[str, Any]] = None
     tags: Optional[List["TagAdapter"]] = None
 
+    @field_validator("category")
+    def category_validate_enum(cls, value):
+        """Validates the enum"""
+        if value is None:
+            return value
+
+        if value not in set(
+            [
+                "API",
+                "AI_MODEL",
+                "VECTOR_DB",
+                "RELATIONAL_DB",
+                "MESSAGE_BROKER",
+                "GIT",
+                "EMAIL",
+                "MCP",
+                "CLOUD",
+            ]
+        ):
+            raise ValueError(
+                "must be one of enum values ('API', 'AI_MODEL', 'VECTOR_DB', 'RELATIONAL_DB', 'MESSAGE_BROKER', 'GIT', 'EMAIL', 'MCP', 'CLOUD')"
+            )
+        return value
+
     @classmethod
     def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
         """Create an instance of Integration from a dict"""
@@ -53,6 +78,8 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
 from conductor.asyncio_client.adapters.models.integration_api_adapter import (  # noqa: E402
     IntegrationApiAdapter,
 )
-from conductor.asyncio_client.adapters.models.tag_adapter import TagAdapter  # noqa: E402
+from conductor.asyncio_client.adapters.models.tag_adapter import (
+    TagAdapter,
+)  # noqa: E402
 
 IntegrationAdapter.model_rebuild(raise_errors=False)

src/conductor/asyncio_client/adapters/models/integration_adapter.py

@@ -26,10 +26,11 @@ def category_validate_enum(cls, value):
                 "GIT",
                 "EMAIL",
                 "MCP",
+                "CLOUD",
             ]
         ):
             raise ValueError(
-                "must be one of enum values ('API', 'AI_MODEL', 'VECTOR_DB', 'RELATIONAL_DB', 'MESSAGE_BROKER', 'GIT', 'EMAIL', 'MCP')"
+                "must be one of enum values ('API', 'AI_MODEL', 'VECTOR_DB', 'RELATIONAL_DB', 'MESSAGE_BROKER', 'GIT', 'EMAIL', 'MCP', 'CLOUD')"
             )
         return value
 

src/conductor/asyncio_client/adapters/models/integration_def_adapter.py

@@ -2,7 +2,7 @@
 
 from typing import Any, ClassVar, Dict, List, Optional
 
-from pydantic import Field
+from pydantic import Field, field_validator
 from typing_extensions import Self
 
 from conductor.asyncio_client.http.models import IntegrationDefFormField
@@ -27,6 +27,96 @@ class IntegrationDefFormFieldAdapter(IntegrationDefFormField):
         "dependsOn",
     ]
 
+    @field_validator("field_name")
+    def field_name_validate_enum(cls, value):
+        """Validates the enum"""
+        if value is None:
+            return value
+
+        if value not in set(
+            [
+                "api_key",
+                "authenticationType",
+                "authUrl",
+                "awsAccountId",
+                "batchPollConsumersCount",
+                "batchSize",
+                "batchWaitTime",
+                "betaVersion",
+                "channel",
+                "cipherSuite",
+                'completionsPath',
+                "connectionPoolSize",
+                "connectionType",
+                "consumer",
+                "consumer_type",
+                "datasourceURL",
+                "dimensions",
+                "distance_metric",
+                "endpoint",
+                "environment",
+                "externalId",
+                "file",
+                "groupId",
+                "header",
+                "indexing_method",
+                "indexName",
+                "inverted_list_count",
+                "jdbcDriver",
+                "keyStoreLocation",
+                "keyStorePassword",
+                "mechanism",
+                "namespace",
+                "organizationId",
+                "password",
+                "port",
+                "projectName",
+                "protocol",
+                "pubSubMethod",
+                "publisher",
+                "pullBatchWaitMillis",
+                "pullPeriod",
+                "queueManager",
+                "region",
+                "roleArn",
+                "schemaRegistryApiKey",
+                "schemaRegistryApiSecret",
+                "schemaRegistryAuthType",
+                "schemaRegistryUrl",
+                "serviceAccountCredentials",
+                "stream",
+                "subscription",
+                "tls",
+                "tlsFile",
+                "truststoreAuthenticationType",
+                "user",
+                "valueSubjectNameStrategy",
+                "version",
+                "visibilityTimeout",
+            ]
+        ):
+            raise ValueError(
+                "must be one of enum values ("
+                "'api_key', 'authenticationType', 'authUrl', 'awsAccountId', "
+                "'batchPollConsumersCount', 'batchSize', 'batchWaitTime', "
+                "'betaVersion', 'channel', 'cipherSuite', 'completionsPath', "
+                "'connectionPoolSize', 'connectionType', 'consumer', 'consumer_type', "
+                "'datasourceURL', 'dimensions', 'distance_metric', 'endpoint', "
+                "'environment', 'externalId', 'file', 'groupId', 'header', "
+                "'indexing_method', 'indexName', 'inverted_list_count', 'jdbcDriver', "
+                "'keyStoreLocation', 'keyStorePassword', 'mechanism', 'namespace', "
+                "'organizationId', 'password', 'port', 'projectName', 'protocol', "
+                "'pubSubMethod', 'publisher', 'pullBatchWaitMillis', 'pullPeriod', "
+                "'queueManager', 'region', 'roleArn', 'schemaRegistryApiKey', "
+                "'schemaRegistryApiSecret', 'schemaRegistryAuthType', 'schemaRegistryUrl', "
+                "'serviceAccountCredentials', 'stream', 'subscription', 'tls', 'tlsFile', "
+                "'truststoreAuthenticationType', 'user', 'valueSubjectNameStrategy', "
+                "'version', 'visibilityTimeout'"
+                ")"
+            )
+
+        return value
+
     @classmethod
     def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
         """Create an instance of IntegrationDefFormField from a dict"""

src/conductor/asyncio_client/adapters/models/integration_def_form_field_adapter.py

@@ -1,5 +1,6 @@
-from conductor.asyncio_client.adapters.api.event_resource_api import \
-    EventResourceApiAdapter
+from conductor.asyncio_client.adapters.api.event_resource_api import (
+    EventResourceApiAdapter,
+)
 from conductor.asyncio_client.adapters import ApiClient
 from conductor.shared.event.configuration import QueueConfiguration
 

src/conductor/asyncio_client/event/event_client.py

@@ -10,14 +10,16 @@
 
 
 class ApiClientAdapter(ApiClient):
-    def __init__(
-        self, configuration=None, header_name=None, header_value=None, cookie=None
-    ):
+    def __init__(self, configuration=None, header_name=None, header_value=None, cookie=None):
         """Initialize the API client adapter with httpx-based REST client."""
-        super().__init__(configuration, header_name, header_value, cookie)
-        self.rest_client = RESTClientObjectAdapter(
-            connection=configuration.http_connection if configuration else None
-        )
+        self.configuration = configuration or Configuration()
+
+        # Create httpx-compatible REST client directly
+        self.rest_client = RESTClientObjectAdapter(connection=self.configuration.http_connection)
+
+        self.default_headers = self._ApiClient__get_default_headers(header_name, header_value)
+        self.cookie = cookie
+        self._ApiClient__refresh_auth_token()
 
     def __call_api(
         self,

src/conductor/client/adapters/api_client_adapter.py

@@ -142,6 +142,7 @@ def category(self, category):
             "GIT",
             "EMAIL",
             "MCP",
+            "CLOUD",
         ]  # noqa: E501
         if category not in allowed_values:
             raise ValueError(

src/conductor/client/adapters/models/integration_adapter.py

@@ -102,6 +102,7 @@ def category(self, category):
             "GIT",
             "EMAIL",
             "MCP",
+            "CLOUD",
         ]  # noqa: E501
         if category not in allowed_values:
             raise ValueError(