fix(compute_log_managers): bugs surfaced by live Docker validation (v0.10.18)

The end-to-end Docker demo (Splunk + OTel Collector + Dagster, scripted
in dagster-community-components-cli/examples/setup_compute_log_managers_demo.sh)
caught two bugs in v0.10.16/17:

1. PollingComputeLogSubscriptionManager imported from wrong module.
   Was: dagster._core.storage.local_compute_log_manager (doesn't export it)
   Now: dagster._core.storage.cloud_storage_compute_log_manager
   Fixed in splunk, otlp, tee.

2. _key_tuple used int(io_type) but ComputeIOType is an Enum, not IntEnum.
   Was: ("/".join(log_key), int(io_type), bool(partial))
        → "int() argument must be a string ... not 'ComputeIOType'"
   Now: ("/".join(log_key), io_type.value, bool(partial))
   Fixed in splunk + otlp.

Validated live (validation in the demo script auto-checks via Splunk
search API): 22 events landed on each path (direct HEC source=dagster,
OTel Collector source=otel-collector) for a 10-line print asset.
Structured fields (dagster_run_id, dagster_step_key, dagster_io_type)
all present.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: eric-thomas-dagster

compute_log_managers/otlp/compute_log_manager.py

@@ -60,10 +60,12 @@
     TruncatingCloudStorageComputeLogManager,
 )
 from dagster._core.storage.compute_log_manager import ComputeIOType
+from dagster._core.storage.cloud_storage_compute_log_manager import (
+    PollingComputeLogSubscriptionManager,
+)
 from dagster._core.storage.local_compute_log_manager import (
     IO_TYPE_EXTENSION,
     LocalComputeLogManager,
-    PollingComputeLogSubscriptionManager,
 )
 from dagster._serdes import ConfigurableClass, ConfigurableClassData
 from dagster._utils import ensure_dir
@@ -349,7 +351,9 @@ def dispose(self):
 
     @staticmethod
     def _key_tuple(log_key: Sequence[str], io_type: ComputeIOType, partial: bool) -> tuple:
-        return ("/".join(log_key), int(io_type), bool(partial))
+        # ComputeIOType is an Enum (.value is "stdout"/"stderr") — use the
+        # value, not int(), since it's not an IntEnum.
+        return ("/".join(log_key), io_type.value, bool(partial))
 
     def _build_envelope(self, lines, attrs, severity, severity_text):
         """Build one OTLP/HTTP logs envelope for a batch of lines.

compute_log_managers/splunk/compute_log_manager.py

@@ -171,7 +171,7 @@ def __init__(
         self._session = None
 
         # Subscription manager — polls local files for live UI streaming.
-        from dagster._core.storage.local_compute_log_manager import (
+        from dagster._core.storage.cloud_storage_compute_log_manager import (
             PollingComputeLogSubscriptionManager,
         )
         self._subscription_manager = PollingComputeLogSubscriptionManager(self)
@@ -368,7 +368,9 @@ def dispose(self):
 
     @staticmethod
     def _key_tuple(log_key: Sequence[str], io_type: ComputeIOType, partial: bool) -> tuple:
-        return ("/".join(log_key), int(io_type), bool(partial))
+        # ComputeIOType is an Enum (.value is "stdout"/"stderr") — use the
+        # value, not int(), since it's not an IntEnum.
+        return ("/".join(log_key), io_type.value, bool(partial))
 
     def _post_hec(self, body: str) -> None:
         """POST a batch of HEC events. Raises on non-200 — caller's caller

compute_log_managers/tee/compute_log_manager.py

@@ -49,12 +49,12 @@
 from dagster import Field, StringSource, _check as check
 from dagster._core.storage.cloud_storage_compute_log_manager import (
     CloudStorageComputeLogManager,
+    PollingComputeLogSubscriptionManager,
     TruncatingCloudStorageComputeLogManager,
 )
 from dagster._core.storage.compute_log_manager import ComputeIOType
 from dagster._core.storage.local_compute_log_manager import (
     LocalComputeLogManager,
-    PollingComputeLogSubscriptionManager,
 )
 from dagster._serdes import ConfigurableClass, ConfigurableClassData
 from dagster_shared import seven

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "dagster-community-components"
-version = "0.10.17"
+version = "0.10.18"
 description = "Community-maintained Dagster components — ingestion, transforms, IO managers, sensors, sinks, resources, and more."
 readme = "README.md"
 requires-python = ">=3.10"