UN-2870 [FEAT] Add SDK1 feature flag support to workers (#1621)

* UN-2870 [FEAT] Add SDK1 feature flag support to workers This commit adds SDK1 feature flag support to workers, matching the backend implementation pattern used across 19 backend files. Changes: - Added feature flag check to destination_connector.py - Added unstract-sdk1 dependency to pyproject.toml - Added Flipt environment variables to sample.env 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com> * allowed README.md from unstract librarry for docker build * added uv lck --------- Co-authored-by: Claude <noreply@anthropic.com> Co-authored-by: vishnuszipstack <117254672+vishnuszipstack@users.noreply.github.com>

Author: 3 people

docker/dockerfiles/worker-unified.Dockerfile.dockerignore

@@ -53,6 +53,8 @@ Thumbs.db
 **/docs/
 **/*.md
 !README.md
+!unstract
+!unstract/**
 
 # Configuration that shouldn't be in containers
 **/.env*

workers/pyproject.toml

@@ -22,7 +22,8 @@ dependencies = [
  "prometheus-client>=0.17.0,<1.0.0", # Metrics collection
  "psutil>=5.9.0,<6.0.0", # System resource monitoring
  # Essential Unstract packages - with Azure support for connectors
- "unstract-sdk[azure]~=0.78.0", # Core SDK with Azure connector support
+ "unstract-sdk[aws,gcs,azure]~=0.78.0", # Core SDK with Azure connector support
+ "unstract-sdk1[aws,gcs,azure]", # SDK v1 for feature flag support
  "unstract-connectors",
  "unstract-core",
  "unstract-flags",
@@ -192,3 +193,4 @@ unstract-tool-registry = { path = "../unstract/tool-registry", editable = true }
 unstract-flags = { path = "../unstract/flags", editable = true }
 unstract-connectors = { path = "../unstract/connectors", editable = true }
 unstract-core = { path = "../unstract/core", editable = true }
+unstract-sdk1 = { path = "../unstract/sdk1", editable = true }

workers/sample.env

@@ -377,4 +377,8 @@ GOOGLE_OAUTH2_SECRET=
 # WORKFLOW_EXECUTION_FILE_STORAGE_CREDENTIALS={"provider": "minio", "credentials": {"endpoint_url": "http://localhost:9000", "key": "minio", "secret": "minio123"}}
 # API_FILE_STORAGE_CREDENTIALS={"provider": "minio", "credentials": {"endpoint_url": "http://localhost:9000", "key": "minio", "secret": "minio123"}}
 
+# Flipt Service
+FLIPT_SERVICE_AVAILABLE=False
+EVALUATION_SERVER_IP=unstract-flipt
+EVALUATION_SERVER_PORT=9005
 PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION=python

workers/shared/workflow/destination_connector.py

@@ -42,8 +42,15 @@
  FileExecutionStatusTracker,
 )
 from unstract.filesystem import FileStorageType, FileSystem
-from unstract.sdk.constants import ToolExecKey
-from unstract.sdk.tool.mime_types import EXT_MIME_MAP
+from unstract.flags.feature_flag import check_feature_flag_status
+
+if check_feature_flag_status("sdk1"):
+ from unstract.sdk1.constants import ToolExecKey
+ from unstract.sdk1.tool.mime_types import EXT_MIME_MAP
+else:
+ from unstract.sdk.constants import ToolExecKey
+ from unstract.sdk.tool.mime_types import EXT_MIME_MAP
+
 from unstract.workflow_execution.constants import (
  MetaDataKey,
  ToolMetadataKey,