refactor: add required=True to necessary components

src/backend/base/langflow/components/Notion/add_content_to_page.py

@@ -32,6 +32,7 @@ class AddContentToPage(LCToolComponent):
             name="block_id",
             display_name="Page/Block ID",
             info="The ID of the page/block to add the content.",
+            required=True,
         ),
         SecretStrInput(
             name="notion_secret",

src/backend/base/langflow/components/Notion/create_page.py

@@ -22,6 +22,7 @@ class NotionPageCreator(LCToolComponent):
             name="database_id",
             display_name="Database ID",
             info="The ID of the Notion database.",
+            required=True,
         ),
         SecretStrInput(
             name="notion_secret",

src/backend/base/langflow/components/Notion/list_database_properties.py

@@ -20,6 +20,7 @@ class NotionDatabaseProperties(LCToolComponent):
             name="database_id",
             display_name="Database ID",
             info="The ID of the Notion database.",
+            required=True,
         ),
         SecretStrInput(
             name="notion_secret",

src/backend/base/langflow/components/Notion/list_pages.py

@@ -35,6 +35,7 @@ class NotionListPages(LCToolComponent):
             name="database_id",
             display_name="Database ID",
             info="The ID of the Notion database to query.",
+            required=True,
         ),
         MultilineInput(
             name="query_json",

src/backend/base/langflow/components/Notion/page_content_viewer.py

@@ -20,6 +20,7 @@ class NotionPageContent(LCToolComponent):
             name="page_id",
             display_name="Page ID",
             info="The ID of the Notion page to retrieve.",
+            required=True,
         ),
         SecretStrInput(
             name="notion_secret",

src/backend/base/langflow/components/Notion/update_page_property.py

@@ -23,6 +23,7 @@ class NotionPageUpdate(LCToolComponent):
             name="page_id",
             display_name="Page ID",
             info="The ID of the Notion page to update.",
+            required=True,
         ),
         MultilineInput(
             name="properties",

src/backend/base/langflow/components/data/directory.py

@@ -19,6 +19,7 @@ class DirectoryComponent(Component):
             info="Path to the directory to load files from. Defaults to current directory ('.')",
             value=".",
             tool_mode=True,
+            required=True,
         ),
         MultiselectInput(
             name="types",

src/backend/base/langflow/components/inputs/chat.py

@@ -30,6 +30,7 @@ class ChatInput(ChatComponent):
             value="",
             info="Message to be passed as input.",
             input_types=[],
+            required=True,
         ),
         BoolInput(
             name="should_store_message",

src/backend/base/langflow/components/inputs/text.py

@@ -14,6 +14,7 @@ class TextInputComponent(TextComponent):
             name="input_value",
             display_name="Text",
             info="Text to be passed as input.",
+            required=True,
         ),
     ]
     outputs = [

src/backend/base/langflow/components/processing/alter_metadata.py

@@ -15,7 +15,7 @@ class AlterMetadataComponent(Component):
             name="input_value",
             display_name="Input",
             info="Object(s) to which Metadata should be added",
-            required=False,
+            required=True,
             input_types=["Message", "Data"],
             is_list=True,
         ),

src/backend/base/langflow/components/processing/combine_text.py

@@ -14,11 +14,13 @@ class CombineTextComponent(Component):
             name="text1",
             display_name="First Text",
             info="The first text input to concatenate.",
+            required=True,
         ),
         MessageTextInput(
             name="text2",
             display_name="Second Text",
             info="The second text input to concatenate.",
+            required=True,
         ),
         MessageTextInput(
             name="delimiter",

src/backend/base/langflow/components/processing/dataframe_operations.py

@@ -26,13 +26,15 @@ class DataFrameOperationsComponent(Component):
             name="df",
             display_name="DataFrame",
             info="The input DataFrame to operate on.",
+            required=True,
         ),
         DropdownInput(
             name="operation",
             display_name="Operation",
             options=OPERATION_CHOICES,
             info="Select the DataFrame operation to perform.",
             real_time_refresh=True,
+            required=True,
         ),
         StrInput(
             name="column_name",

src/backend/base/langflow/components/processing/filter_data.py

@@ -15,12 +15,14 @@ class FilterDataComponent(Component):
             name="data",
             display_name="Data",
             info="Data object to filter.",
+            required=True,
         ),
         MessageTextInput(
             name="filter_criteria",
             display_name="Filter Criteria",
             info="List of keys to filter by.",
             is_list=True,
+            required=True,
         ),
     ]
 

src/backend/base/langflow/components/processing/filter_data_values.py

@@ -16,20 +16,28 @@ class DataFilterComponent(Component):
     name = "FilterDataValues"
 
     inputs = [
-        DataInput(name="input_data", display_name="Input Data", info="The list of data items to filter.", is_list=True),
+        DataInput(
+            name="input_data",
+            display_name="Input Data",
+            info="The list of data items to filter.",
+            is_list=True,
+            required=True,
+        ),
         MessageTextInput(
             name="filter_key",
             display_name="Filter Key",
             info="The key to filter on (e.g., 'route').",
-            value="route",
+            value="",
             input_types=["Data"],
+            required=True,
         ),
         MessageTextInput(
             name="filter_value",
             display_name="Filter Value",
             info="The value to filter by (e.g., 'CMIP').",
-            value="CMIP",
+            value="",
             input_types=["Data"],
+            required=True,
         ),
         DropdownInput(
             name="operator",

src/backend/base/langflow/components/processing/message_to_data.py

@@ -18,6 +18,7 @@ class MessageToDataComponent(Component):
             name="message",
             display_name="Message",
             info="The Message object to convert to a Data object",
+            required=True,
         ),
     ]
 

src/backend/base/langflow/components/processing/update_data.py

@@ -27,6 +27,7 @@ class UpdateDataComponent(Component):
             display_name="Data",
             info="The record to update.",
             is_list=True,  # Changed to True to handle list of Data objects
+            required=True,
         ),
         IntInput(
             name="number_of_fields",

src/backend/base/langflow/components/prompts/prompt.py

@@ -14,7 +14,7 @@ class PromptComponent(Component):
     name = "Prompt"
 
     inputs = [
-        PromptInput(name="template", display_name="Template"),
+        PromptInput(name="template", display_name="Template", required=True),
         MessageTextInput(
             name="tool_placeholder",
             display_name="Tool Placeholder",

src/backend/base/langflow/components/vectorstores/astradb.py

@@ -103,6 +103,7 @@ class AstraDBVectorStoreComponent(LCVectorStoreComponent):
             display_name="Embedding Model",
             input_types=["Embeddings"],
             info="Allows an embedding model configuration.",
+            required=True,
         ),
         *base_inputs,
         IntInput(

src/backend/base/langflow/components/vectorstores/astradb_graph.py

@@ -64,6 +64,7 @@ class AstraDBGraphVectorStoreComponent(LCVectorStoreComponent):
             display_name="Embedding Model",
             input_types=["Embeddings"],
             info="Allows an embedding model configuration.",
+            required=True,
         ),
         DropdownInput(
             name="metric",

src/backend/base/langflow/components/vectorstores/cassandra.py

@@ -77,7 +77,7 @@ class CassandraVectorStoreComponent(LCVectorStoreComponent):
             list=True,
         ),
         *LCVectorStoreComponent.inputs,
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         IntInput(
             name="number_of_results",
             display_name="Number of Results",

src/backend/base/langflow/components/vectorstores/cassandra_graph.py

@@ -65,7 +65,7 @@ class CassandraGraphVectorStoreComponent(LCVectorStoreComponent):
             list=True,
         ),
         *LCVectorStoreComponent.inputs,
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         IntInput(
             name="number_of_results",
             display_name="Number of Results",

src/backend/base/langflow/components/vectorstores/chroma.py

@@ -23,13 +23,15 @@ class ChromaVectorStoreComponent(LCVectorStoreComponent):
             name="collection_name",
             display_name="Collection Name",
             value="langflow",
+            required=True,
         ),
         StrInput(
             name="persist_directory",
             display_name="Persist Directory",
+            required=True,
         ),
         *LCVectorStoreComponent.inputs,
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         StrInput(
             name="chroma_server_cors_allow_origins",
             display_name="Server CORS Allow Origins",

src/backend/base/langflow/components/vectorstores/clickhouse.py

@@ -52,7 +52,7 @@ class ClickhouseVectorStoreComponent(LCVectorStoreComponent):
         StrInput(name="index_param", display_name="Param of the index", value="'L2Distance',100", advanced=True),
         DictInput(name="index_query_params", display_name="index query params", advanced=True),
         *LCVectorStoreComponent.inputs,
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         IntInput(
             name="number_of_results",
             display_name="Number of Results",

src/backend/base/langflow/components/vectorstores/couchbase.py

@@ -25,7 +25,7 @@ class CouchbaseVectorStoreComponent(LCVectorStoreComponent):
         StrInput(name="collection_name", display_name="Collection Name", required=True),
         StrInput(name="index_name", display_name="Index Name", required=True),
         *LCVectorStoreComponent.inputs,
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         IntInput(
             name="number_of_results",
             display_name="Number of Results",

src/backend/base/langflow/components/vectorstores/elasticsearch.py

@@ -48,6 +48,7 @@ class ElasticsearchVectorStoreComponent(LCVectorStoreComponent):
             name="username",
             display_name="Username",
             value="",
+            required=True,
             advanced=False,
             info=(
                 "Elasticsearch username (e.g., 'elastic'). "
@@ -58,6 +59,7 @@ class ElasticsearchVectorStoreComponent(LCVectorStoreComponent):
             name="password",
             display_name="Password",
             value="",
+            required=True,
             advanced=False,
             info=(
                 "Elasticsearch password for the specified user. "
@@ -68,6 +70,7 @@ class ElasticsearchVectorStoreComponent(LCVectorStoreComponent):
             name="embedding",
             display_name="Embedding",
             input_types=["Embeddings"],
+            required=True,
         ),
         DropdownInput(
             name="search_type",

src/backend/base/langflow/components/vectorstores/faiss.py

@@ -19,11 +19,13 @@ class FaissVectorStoreComponent(LCVectorStoreComponent):
             name="index_name",
             display_name="Index Name",
             value="langflow_index",
+            required=True,
         ),
         StrInput(
             name="persist_directory",
             display_name="Persist Directory",
             info="Path to save the FAISS index. It will be relative to where Langflow is running.",
+            required=True,
         ),
         *LCVectorStoreComponent.inputs,
         BoolInput(
@@ -34,7 +36,7 @@ class FaissVectorStoreComponent(LCVectorStoreComponent):
             advanced=True,
             value=True,
         ),
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         IntInput(
             name="number_of_results",
             display_name="Number of Results",

src/backend/base/langflow/components/vectorstores/hcd.py

@@ -116,6 +116,7 @@ class HCDVectorStoreComponent(LCVectorStoreComponent):
             name="embedding",
             display_name="Embedding or Astra Vectorize",
             input_types=["Embeddings", "dict"],
+            required=True,
             # TODO: This should be optional, but need to refactor langchain-astradb first.
             info="Allows either an embedding model or an Astra Vectorize configuration.",
         ),

src/backend/base/langflow/components/vectorstores/milvus.py

@@ -22,18 +22,20 @@ class MilvusVectorStoreComponent(LCVectorStoreComponent):
     icon = "Milvus"
 
     inputs = [
-        StrInput(name="collection_name", display_name="Collection Name", value="langflow"),
+        StrInput(name="collection_name", display_name="Collection Name", value="langflow", required=True),
         StrInput(name="collection_description", display_name="Collection Description", value=""),
         StrInput(
             name="uri",
             display_name="Connection URI",
             value="http://localhost:19530",
+            required=True,
         ),
         SecretStrInput(
             name="password",
             display_name="Token",
             value="",
             info="Ignore this field if no token is required to make connection.",
+            required=True,
         ),
         DictInput(name="connection_args", display_name="Other Connection Arguments", advanced=True),
         StrInput(name="primary_field", display_name="Primary Field Name", value="pk"),
@@ -51,7 +53,7 @@ class MilvusVectorStoreComponent(LCVectorStoreComponent):
         BoolInput(name="drop_old", display_name="Drop Old Collection", value=False, advanced=True),
         FloatInput(name="timeout", display_name="Timeout", advanced=True),
         *LCVectorStoreComponent.inputs,
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         IntInput(
             name="number_of_results",
             display_name="Number of Results",

src/backend/base/langflow/components/vectorstores/mongodb_atlas.py

@@ -30,7 +30,7 @@ class MongoVectorStoreComponent(LCVectorStoreComponent):
         StrInput(name="collection_name", display_name="Collection Name", required=True),
         StrInput(name="index_name", display_name="Index Name", required=True),
         *LCVectorStoreComponent.inputs,
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         IntInput(
             name="number_of_results",
             display_name="Number of Results",

src/backend/base/langflow/components/vectorstores/opensearch.py

@@ -31,15 +31,17 @@ class OpenSearchVectorStoreComponent(LCVectorStoreComponent):
             display_name="OpenSearch URL",
             value="http://localhost:9200",
             info="URL for OpenSearch cluster (e.g. https://192.168.1.1:9200).",
+            required=True,
         ),
         StrInput(
             name="index_name",
             display_name="Index Name",
             value="langflow",
             info="The index name where the vectors will be stored in OpenSearch cluster.",
+            required=True,
         ),
         *LCVectorStoreComponent.inputs,
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         DropdownInput(
             name="search_type",
             display_name="Search Type",

src/backend/base/langflow/components/vectorstores/pinecone.py

@@ -31,7 +31,7 @@ class PineconeVectorStoreComponent(LCVectorStoreComponent):
             advanced=True,
         ),
         *LCVectorStoreComponent.inputs,
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         IntInput(
             name="number_of_results",
             display_name="Number of Results",

src/backend/base/langflow/components/vectorstores/qdrant.py

@@ -38,7 +38,7 @@ class QdrantVectorStoreComponent(LCVectorStoreComponent):
         StrInput(name="content_payload_key", display_name="Content Payload Key", value="page_content", advanced=True),
         StrInput(name="metadata_payload_key", display_name="Metadata Payload Key", value="metadata", advanced=True),
         *LCVectorStoreComponent.inputs,
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
         IntInput(
             name="number_of_results",
             display_name="Number of Results",

src/backend/base/langflow/components/vectorstores/redis.py

@@ -36,7 +36,7 @@ class RedisVectorStoreComponent(LCVectorStoreComponent):
             value=4,
             advanced=True,
         ),
-        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"]),
+        HandleInput(name="embedding", display_name="Embedding", input_types=["Embeddings"], required=True),
     ]
 
     @check_cached_vector_store