twitter_tags : fix

Author: c200bzh

source-twitter-fetcher/source_twitter_fetcher/source.py

@@ -22,11 +22,19 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
             token_refresh_endpoint="https://api.x.com/2/oauth2/token"
         )
 
-        tweet = Tweet(
-            authenticator=auth,
-            account_id=config["account_id"],
-            start_time=datetime.strptime(config['start_time'], DATE_FORMAT),
-        )
+        # Parse start_time if provided, otherwise streams will use their defaults
+        start_time = None
+        if "start_time" in config:
+            start_time = datetime.strptime(config['start_time'], DATE_FORMAT)
+
+        tweet_kwargs = {
+            "authenticator": auth,
+            "account_id": config["account_id"]
+        }
+        if start_time:
+            tweet_kwargs["start_time"] = start_time
+            
+        tweet = Tweet(**tweet_kwargs)
 
         tags_kwargs = {
             "authenticator": auth,
@@ -35,8 +43,8 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
         }
 
         # Add start_time only if provided in config
-        if "start_time" in config:
-            tags_kwargs["start_time"] = datetime.strptime(config['start_time'], DATE_FORMAT)
+        if start_time:
+            tags_kwargs["start_time"] = start_time
 
         # Add tags_frequent_extractions if provided in config
         if "tags_frequent_extractions" in config:
@@ -56,11 +64,14 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
             parent=tweet
         )
 
-        promoted_tweet_active = PromotedTweetActive(
-            authenticator=auth,
-            account_id=config['account_id'],
-            start_time=datetime.strptime(config['start_time'], DATE_FORMAT),
-        )
+        promoted_tweet_active_kwargs = {
+            "authenticator": auth,
+            "account_id": config['account_id']
+        }
+        if start_time:
+            promoted_tweet_active_kwargs["start_time"] = start_time
+            
+        promoted_tweet_active = PromotedTweetActive(**promoted_tweet_active_kwargs)
 
         promoted_tweet_billing = PromotedTweetBilling(
             authenticator=auth,
@@ -74,11 +85,14 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
             parent=promoted_tweet_active
         )
 
-        space = Space(
-            authenticator=auth,
-            account_id=config['account_id'],
-            start_time=datetime.strptime(config['start_time'], DATE_FORMAT)
-        )
+        space_kwargs = {
+            "authenticator": auth,
+            "account_id": config['account_id']
+        }
+        if start_time:
+            space_kwargs["start_time"] = start_time
+            
+        space = Space(**space_kwargs)
 
         return [
             Account(authenticator=auth, account_id=config["account_id"]),

source-twitter-fetcher/source_twitter_fetcher/spec.yaml

@@ -50,7 +50,7 @@ connectionSpecification:
       description: "List of Twitter handles to monitor (e.g., ['@IFT', '@Airbyte'])"
       items:
         type: string
-      minItems: 1 
+      minItems: 1
     tags_frequent_extractions:
       type: boolean
       title: "Tags Frequent Extractions"