fix: format

Author: youbek

src/adcp/__init__.py

@@ -101,6 +101,7 @@
     ListCreativeFormatsResponse,
     ListCreativesRequest,
     ListCreativesResponse,
+    McpWebhookPayload,
     MediaBuy,
     MediaBuyStatus,
     Package,
@@ -170,7 +171,6 @@
     UrlPreviewRender,
     UrlVastAsset,
 )
-from adcp.types import McpWebhookPayload
 from adcp.types.core import AgentConfig, Protocol, TaskResult, TaskStatus, WebhookMetadata
 from adcp.validation import (
     ValidationError,

src/adcp/client.py

@@ -15,7 +15,6 @@
 from pydantic import BaseModel
 
 from adcp.exceptions import ADCPWebhookSignatureError
-from adcp.types.generated_poc.core.async_response_data import AdcpAsyncResponseData
 from adcp.protocols.a2a import A2AAdapter
 from adcp.protocols.base import ProtocolAdapter
 from adcp.protocols.mcp import MCPAdapter
@@ -56,6 +55,7 @@
     TaskResult,
     TaskStatus,
 )
+from adcp.types.generated_poc.core.async_response_data import AdcpAsyncResponseData
 from adcp.utils.operation_id import create_operation_id
 
 logger = logging.getLogger(__name__)
@@ -1028,8 +1028,8 @@ async def _handle_a2a_webhook(
 
         Per A2A specification:
         - Terminated statuses (completed, failed): Payload is Task with artifacts[].parts[]
-        - Intermediate statuses (working, input-required, submitted): Payload is TaskStatusUpdateEvent
-          with status.message.parts[]
+        - Intermediate statuses (working, input-required, submitted):
+        Payload is TaskStatusUpdateEvent with status.message.parts[]
 
         Args:
             payload: A2A Task or TaskStatusUpdateEvent object

src/adcp/types/__init__.py

@@ -16,11 +16,9 @@
 
 # Import all types from generated code
 from adcp.types._generated import (
-    # Core request/response types
     ActivateSignalRequest,
     ActivateSignalResponse,
     AggregatedTotals,
-    # Assets
     Asset,
     AssetContentType,
     AssetSelectors,
@@ -41,7 +39,6 @@
     Colors,
     Contact,
     Country,
-    # Pricing options
     CpcPricingOption,
     CpcvPricingOption,
     CpmAuctionPricingOption,
@@ -59,7 +56,6 @@
     CreativeFilters,
     CreativeManifest,
     CreativePolicy,
-    # Enums and constants
     CreativeStatus,
     CssAsset,
     DaastTrackingEvent,
@@ -195,77 +191,54 @@
     WebhookAsset,
     WebhookResponseType,
 )
-from adcp.types._generated import (
-    TaskStatus as GeneratedTaskStatus,
-)
-from adcp.types._generated import (
-    _PackageFromPackage as Package,
-)
+from adcp.types._generated import TaskStatus as GeneratedTaskStatus
+from adcp.types._generated import _PackageFromPackage as Package
 
 # Import semantic aliases for discriminated unions
 from adcp.types.aliases import (
-    # Activation responses
     ActivateSignalErrorResponse,
     ActivateSignalSuccessResponse,
-    # Agent deployment aliases
     AgentDeployment,
     AgentDestination,
-    # Authorized agent variants
     AuthorizedAgent,
     AuthorizedAgentsByInlineProperties,
     AuthorizedAgentsByPropertyId,
     AuthorizedAgentsByPropertyTag,
     AuthorizedAgentsByPublisherProperties,
-    # Preview/render aliases
     BothPreviewRender,
-    # Build creative responses
     BuildCreativeErrorResponse,
     BuildCreativeSuccessResponse,
-    # Create media buy responses
     CreateMediaBuyErrorResponse,
     CreateMediaBuySuccessResponse,
-    # Deployment union
     Deployment,
-    # Destination union
     Destination,
-    # Preview renders
     HtmlPreviewRender,
-    # Asset aliases
     InlineDaastAsset,
     InlineVastAsset,
-    # SubAsset aliases
     MediaSubAsset,
-    # Platform deployment
     PlatformDeployment,
     PlatformDestination,
-    # Preview requests
     PreviewCreativeFormatRequest,
     PreviewCreativeInteractiveResponse,
     PreviewCreativeManifestRequest,
     PreviewCreativeStaticResponse,
-    # Publisher property selectors
     PropertyId,
     PropertyIdActivationKey,
     PropertyTag,
     PropertyTagActivationKey,
     ProvidePerformanceFeedbackErrorResponse,
     ProvidePerformanceFeedbackSuccessResponse,
-    # Publisher properties variants
     PublisherPropertiesAll,
     PublisherPropertiesById,
     PublisherPropertiesByTag,
-    # Sync responses
+    SyncCreativeResult,
     SyncCreativesErrorResponse,
     SyncCreativesSuccessResponse,
-    SyncCreativeResult,
-    # Text subassets
     TextSubAsset,
-    # Update media buy variants
     UpdateMediaBuyErrorResponse,
     UpdateMediaBuyPackagesRequest,
     UpdateMediaBuyPropertiesRequest,
     UpdateMediaBuySuccessResponse,
-    # URL aliases
     UrlDaastAsset,
     UrlPreviewRender,
     UrlVastAsset,

src/adcp/webhooks.py

@@ -156,7 +156,7 @@ def get_adcp_signed_headers_for_webhook(
 
     Examples:
         Sign and send an MCP webhook:
-        >>> from adcp.webhooks import create_mcp_webhook_payload, get_adcp_signed_headers_for_webhook
+        >>> from adcp.webhooks import create_mcp_webhook_payload get_adcp_signed_headers_for_webhook
         >>> from datetime import datetime, timezone
         >>>
         >>> payload = create_mcp_webhook_payload(
@@ -270,7 +270,13 @@ def extract_webhook_result_data(webhook_payload: dict[str, Any]) -> AdcpAsyncRes
         ...         {
         ...             "artifact_id": "artifact_456",
         ...             "parts": [
-        ...                 {"data": {"media_buy_id": "mb_456", "buyer_ref": "ref_456", "packages": []}}
+        ...                 {
+        ...                     "data": {
+        ...                         "media_buy_id": "mb_456",
+        ...                         "buyer_ref": "ref_456",
+        ...                         "packages": []
+        ...                     }
+        ...                 }
         ...             ]
         ...         }
         ...     ]