Merge pull request #30 from mondaycom/feature/michaelim/fetch-updates-incrementaly

Enhance UpdateModule with date filtering and incremental fetch

Author: michaelimas

setup.py

@@ -15,7 +15,7 @@
 
 setup(
     name="monday-api-python-sdk",  # Required
-    version="1.4.8",  # Required
+    version="1.5.0",  # Required
     description="A Python SDK for interacting with Monday's GraphQL API",  # Optional
     long_description=long_description,  # Optional
     long_description_content_type="text/markdown",  # Optional (see note above)

src/monday_sdk/constants.py

@@ -1,5 +1,5 @@
 API_URL = "https://api.monday.com/v2"
-API_VERSION = "2025-07"
+API_VERSION = "2026-01"
 TOKEN_HEADER = "Authorization"
 MAX_COMPLEXITY = 10000000  # Monday's API complexity limit per minute
 

src/monday_sdk/modules/updates.py

@@ -24,8 +24,13 @@ def fetch_updates_for_item(self, item_id, limit=100) -> MondayApiResponse:
         query = get_updates_for_item_query(item_id=item_id, limit=limit)
         return self.client.execute(query)
 
-    def fetch_board_updates_page(self, board_id, limit=100, page=1) -> List[Update]:
-        query = get_updates_for_board(board_id, limit, page)
+    def fetch_board_updates_page(self, board_id, limit=100, page=1, from_date: Optional[str] = None, to_date: Optional[str] = None) -> List[Update]:
+        """
+        Fetches a single page of updates from a board.
+        
+        Note: from_date and to_date parameters require Monday API version 2026-01+
+        """
+        query = get_updates_for_board(board_id, limit, page, from_date, to_date)
         response: MondayApiResponse = self.client.execute(query)
         return response.data.boards[0].updates
 
@@ -64,4 +69,35 @@ def fetch_board_updates(
             all_updates.extend(updates)
             page += 1
 
-        return all_updates
+        return all_updates
+
+    def fetch_board_updates_incremental(
+        self,
+        board_id: str,
+        limit: int = 100,
+        page: int = 1,
+        from_date: Optional[str] = None,
+        to_date: Optional[str] = None,
+    ) -> List[Update]:
+        """
+        Fetches updates from a board using Monday's native incremental fetch API.
+        Uses the API's built-in date filtering instead of client-side filtering.
+        
+        **Requires API version 2026-01 or later**
+        
+        Args:
+            board_id: The board ID to fetch updates from
+            limit: Maximum number of updates per page (default: 100)
+            page: Page number to fetch (default: 1)
+            from_date: Start date in ISO format (e.g., "2025-10-10T00:00:00Z")
+            to_date: End date in ISO format (e.g., "2025-11-11T00:00:00Z")
+        
+        Returns:
+            List of Update objects
+            
+        Note:
+            The from_date and to_date parameters require Monday API version 2026-01+.
+            If using an older API version, use fetch_board_updates() instead which 
+            provides client-side date filtering.
+        """
+        return self.fetch_board_updates_page(board_id, limit, page, from_date, to_date)

src/monday_sdk/query_templates.py

@@ -544,11 +544,19 @@ def get_updates_for_item_query(item_id, limit: int):
     return query
 
 
-def get_updates_for_board(board_id, limit: int, page=1):
+def get_updates_for_board(board_id, limit: int, page=1, from_date: Optional[str] = None, to_date: Optional[str] = None):
+    # Build the updates parameters
+    updates_params = f"limit: {limit}, page: {page}"
+    
+    if from_date:
+        updates_params += f', from_date: "{from_date}"'
+    if to_date:
+        updates_params += f', to_date: "{to_date}"'
+    
     query = """query
     {
         boards(ids: %s) {
-            updates(limit: %s, page: %s) {
+            updates(%s) {
                 id,
                 text_body,
                 item_id,
@@ -562,8 +570,7 @@ def get_updates_for_board(board_id, limit: int, page=1):
         }
     }""" % (
         board_id,
-        limit,
-        page,
+        updates_params,
     )
 
     return query