Merge pull request #22 from eccenca/feature/explicitSchema-CMEM-6444

Added explicit_schema flag to FlexibleSchemaPort (CMEM-6444)

Author: seebi

CHANGELOG.md

@@ -4,6 +4,13 @@ All notable changes to this project will be documented in this file.
 
 The format is based on [Keep a Changelog](http://keepachangelog.com/) and this project adheres to [Semantic Versioning](https://semver.org/)
 
+## [Unreleased]
+
+### Added
+
+- Added `explicit_schema` parameter to `FlexibleOutputSchema` (CMEM-6444).
+
+
 ## [4.9.0] 2025-02-20
 
 ### Added

cmem_plugin_base/dataintegration/ports.py

@@ -22,8 +22,15 @@ class FlexibleSchemaPort(Port):
     Flexible input ports will adapt the schema to the connected output.
     Flexible output ports will adapt the schema to the connected input.
     It is not allowed to connect two flexible ports.
+
+    :param explicit_schema: Indicates whether an output port has an explicitly defined and quickly
+                            retrievable schema (like CSV). This allows for connecting it directly to
+                            flexible input ports in which case the explict schema will be used.
     """
 
+    def __init__(self, explicit_schema: bool = False):
+        self.explicit_schema = explicit_schema
+
 
 class UnknownSchemaPort(Port):
     """Port for which the schema is not known in advance.