diff --git a/.fern/metadata.json b/.fern/metadata.json
index 61cfdde..670b5e8 100644
--- a/.fern/metadata.json
+++ b/.fern/metadata.json
@@ -1,15 +1,16 @@
 {
-  "cliVersion": "5.38.0",
+  "cliVersion": "5.45.3",
   "generatorName": "fernapi/fern-java-sdk",
-  "generatorVersion": "4.8.11",
+  "generatorVersion": "4.9.2",
   "generatorConfig": {
     "publish-to": "central",
     "client-class-name": "CatchAllApi",
     "package-prefix": "com.newscatcher.catchall"
   },
-  "originGitCommit": "5c18e5b13a9cc97f8ccdc7b91a6cd7b6f13ad6f4",
+  "originGitCommit": "56ea60da11c1b8d90274a137f5fbc3bb89b9fac4",
   "originGitCommitIsDirty": true,
-  "invokedBy": "manual",
-  "requestedVersion": "3.0.0",
-  "sdkVersion": "3.0.0"
+  "invokedBy": "ci",
+  "requestedVersion": "AUTO",
+  "ciProvider": "unknown",
+  "sdkVersion": "3.0.1"
 }
\ No newline at end of file
diff --git a/README.md b/README.md
index 6eff517..de3aa29 100644
--- a/README.md
+++ b/README.md
@@ -35,7 +35,7 @@ Add the dependency in your `build.gradle` file:
 
 ```groovy
 dependencies {
-  implementation 'com.newscatcherapi:newscatcher-catchall-sdk:3.0.0'
+  implementation 'com.newscatcherapi:newscatcher-catchall-sdk:3.0.1'
 }
 ```
 
@@ -47,7 +47,7 @@ Add the dependency in your `pom.xml` file:
 <dependency>
   <groupId>com.newscatcherapi</groupId>
   <artifactId>newscatcher-catchall-sdk</artifactId>
-  <version>3.0.0</version>
+  <version>3.0.1</version>
 </dependency>
 ```
 
@@ -263,3 +263,4 @@ On the other hand, contributions to the README are always very welcome!
 
 
 
+
diff --git a/build.gradle b/build.gradle
index 275971a..7e47163 100644
--- a/build.gradle
+++ b/build.gradle
@@ -47,7 +47,7 @@ java {
 
 group = 'com.newscatcherapi'
 
-version = '3.0.0'
+version = '3.0.1'
 
 jar {
     dependsOn(":generatePomFileForMavenPublication")
@@ -78,7 +78,7 @@ publishing {
         maven(MavenPublication) {
             groupId = 'com.newscatcherapi'
             artifactId = 'newscatcher-catchall-sdk'
-            version = '3.0.0'
+            version = '3.0.1'
             from components.java
             pom {
                 name = 'newscatcher'
diff --git a/reference.md b/reference.md
index d51582c..195040c 100644
--- a/reference.md
+++ b/reference.md
@@ -210,6 +210,25 @@ client.jobs().initialize(
 
 **context:** `Optional<String>` 
     
+</dd>
+</dl>
+
+<dl>
+<dd>
+
+**connectedDatasetIds:** `Optional<List<String>>` — Optional list of watchlist dataset IDs connected to this job.
+    
+</dd>
+</dl>
+
+<dl>
+<dd>
+
+**fetchAllWatchlistNews:** `Optional<Boolean>` 
+
+When true, returns generic news validators and enrichments suitable for
+watchlist-based article collection instead of query-specific fields.
+    
 </dd>
 </dl>
 </dd>
@@ -383,6 +402,30 @@ Only valid when `connected_dataset_ids` is set; otherwise ignored. Records where
 
 **webhookIds:** `Optional<List<String>>` — IDs of webhooks to notify when the job completes. Maximum 5 per job.
     
+</dd>
+</dl>
+
+<dl>
+<dd>
+
+**fetchAllWatchlistNews:** `Optional<Boolean>` 
+
+When true, retrieves all news for connected Company Watchlist entities
+without topic filtering. Requires connected_dataset_ids to be set.
+    
+</dd>
+</dl>
+
+<dl>
+<dd>
+
+**edAssociationType:** `Optional<EntityAssociationType>` 
+
+Filter events by entity association type. `event_associated` keeps only
+events where the entity is a direct actor. `mention` keeps only events
+where the entity is merely referenced. Only relevant when
+connected_dataset_ids is set.
+    
 </dd>
 </dl>
 </dd>
diff --git a/src/main/java/com/newscatcher/catchall/core/ClientOptions.java b/src/main/java/com/newscatcher/catchall/core/ClientOptions.java
index b35cc85..4a5c40b 100644
--- a/src/main/java/com/newscatcher/catchall/core/ClientOptions.java
+++ b/src/main/java/com/newscatcher/catchall/core/ClientOptions.java
@@ -38,10 +38,10 @@ private ClientOptions(
         this.headers.putAll(headers);
         this.headers.putAll(new HashMap<String, String>() {
             {
-                put("User-Agent", "com.newscatcherapi:newscatcher-catchall-sdk/3.0.0");
+                put("User-Agent", "com.newscatcherapi:newscatcher-catchall-sdk/3.0.1");
                 put("X-Fern-Language", "JAVA");
                 put("X-Fern-SDK-Name", "com.newscatcher.fern:api-sdk");
-                put("X-Fern-SDK-Version", "3.0.0");
+                put("X-Fern-SDK-Version", "3.0.1");
             }
         });
         this.headerSuppliers = headerSuppliers;
diff --git a/src/main/java/com/newscatcher/catchall/resources/datasets/AsyncRawDatasetsClient.java b/src/main/java/com/newscatcher/catchall/resources/datasets/AsyncRawDatasetsClient.java
index 5f878f0..acc2ceb 100644
--- a/src/main/java/com/newscatcher/catchall/resources/datasets/AsyncRawDatasetsClient.java
+++ b/src/main/java/com/newscatcher/catchall/resources/datasets/AsyncRawDatasetsClient.java
@@ -392,7 +392,7 @@ public CompletableFuture<CatchAllApiHttpResponse<CreateDatasetCsvResponse>> crea
         Request.Builder _requestBuilder = new Request.Builder();
         _requestBuilder.url(httpUrl.build());
         _requestBuilder.method("POST", body);
-        _requestBuilder.headers(Headers.of(this.clientOptions.headers(null)));
+        _requestBuilder.headers(Headers.of(this.clientOptions.headers((RequestOptions) null)));
         Request okhttpRequest = _requestBuilder.build();
         OkHttpClient client = clientOptions.httpClient();
         CompletableFuture<CatchAllApiHttpResponse<CreateDatasetCsvResponse>> future = new CompletableFuture<>();
@@ -453,7 +453,7 @@ public CompletableFuture<CatchAllApiHttpResponse<CreateDatasetCsvResponse>> crea
         Request.Builder _requestBuilder = new Request.Builder();
         _requestBuilder.url(httpUrl.build());
         _requestBuilder.method("POST", body);
-        _requestBuilder.headers(Headers.of(this.clientOptions.headers(null)));
+        _requestBuilder.headers(Headers.of(this.clientOptions.headers((RequestOptions) null)));
         Request okhttpRequest = _requestBuilder.build();
         OkHttpClient client = clientOptions.httpClient();
         CompletableFuture<CatchAllApiHttpResponse<CreateDatasetCsvResponse>> future = new CompletableFuture<>();
@@ -1439,7 +1439,7 @@ public CompletableFuture<CatchAllApiHttpResponse<UploadCsvToDatasetResponse>> up
         Request.Builder _requestBuilder = new Request.Builder();
         _requestBuilder.url(httpUrl.build());
         _requestBuilder.method("POST", body);
-        _requestBuilder.headers(Headers.of(this.clientOptions.headers(null)));
+        _requestBuilder.headers(Headers.of(this.clientOptions.headers((RequestOptions) null)));
         Request okhttpRequest = _requestBuilder.build();
         OkHttpClient client = clientOptions.httpClient();
         CompletableFuture<CatchAllApiHttpResponse<UploadCsvToDatasetResponse>> future = new CompletableFuture<>();
@@ -1508,7 +1508,7 @@ public CompletableFuture<CatchAllApiHttpResponse<UploadCsvToDatasetResponse>> up
         Request.Builder _requestBuilder = new Request.Builder();
         _requestBuilder.url(httpUrl.build());
         _requestBuilder.method("POST", body);
-        _requestBuilder.headers(Headers.of(this.clientOptions.headers(null)));
+        _requestBuilder.headers(Headers.of(this.clientOptions.headers((RequestOptions) null)));
         Request okhttpRequest = _requestBuilder.build();
         OkHttpClient client = clientOptions.httpClient();
         CompletableFuture<CatchAllApiHttpResponse<UploadCsvToDatasetResponse>> future = new CompletableFuture<>();
diff --git a/src/main/java/com/newscatcher/catchall/resources/datasets/RawDatasetsClient.java b/src/main/java/com/newscatcher/catchall/resources/datasets/RawDatasetsClient.java
index 5657b94..0fa7b2b 100644
--- a/src/main/java/com/newscatcher/catchall/resources/datasets/RawDatasetsClient.java
+++ b/src/main/java/com/newscatcher/catchall/resources/datasets/RawDatasetsClient.java
@@ -335,7 +335,7 @@ public CatchAllApiHttpResponse<CreateDatasetCsvResponse> createDatasetFromCsv(In
         Request.Builder _requestBuilder = new Request.Builder();
         _requestBuilder.url(httpUrl.build());
         _requestBuilder.method("POST", body);
-        _requestBuilder.headers(Headers.of(this.clientOptions.headers(null)));
+        _requestBuilder.headers(Headers.of(this.clientOptions.headers((RequestOptions) null)));
         Request okhttpRequest = _requestBuilder.build();
         OkHttpClient client = clientOptions.httpClient();
         try (Response response = client.newCall(okhttpRequest).execute()) {
@@ -379,7 +379,7 @@ public CatchAllApiHttpResponse<CreateDatasetCsvResponse> createDatasetFromCsv(
         Request.Builder _requestBuilder = new Request.Builder();
         _requestBuilder.url(httpUrl.build());
         _requestBuilder.method("POST", body);
-        _requestBuilder.headers(Headers.of(this.clientOptions.headers(null)));
+        _requestBuilder.headers(Headers.of(this.clientOptions.headers((RequestOptions) null)));
         Request okhttpRequest = _requestBuilder.build();
         OkHttpClient client = clientOptions.httpClient();
         try (Response response = client.newCall(okhttpRequest).execute()) {
@@ -1155,7 +1155,7 @@ public CatchAllApiHttpResponse<UploadCsvToDatasetResponse> uploadCsvToDataset(
         Request.Builder _requestBuilder = new Request.Builder();
         _requestBuilder.url(httpUrl.build());
         _requestBuilder.method("POST", body);
-        _requestBuilder.headers(Headers.of(this.clientOptions.headers(null)));
+        _requestBuilder.headers(Headers.of(this.clientOptions.headers((RequestOptions) null)));
         Request okhttpRequest = _requestBuilder.build();
         OkHttpClient client = clientOptions.httpClient();
         try (Response response = client.newCall(okhttpRequest).execute()) {
@@ -1204,7 +1204,7 @@ public CatchAllApiHttpResponse<UploadCsvToDatasetResponse> uploadCsvToDataset(
         Request.Builder _requestBuilder = new Request.Builder();
         _requestBuilder.url(httpUrl.build());
         _requestBuilder.method("POST", body);
-        _requestBuilder.headers(Headers.of(this.clientOptions.headers(null)));
+        _requestBuilder.headers(Headers.of(this.clientOptions.headers((RequestOptions) null)));
         Request okhttpRequest = _requestBuilder.build();
         OkHttpClient client = clientOptions.httpClient();
         try (Response response = client.newCall(okhttpRequest).execute()) {
diff --git a/src/main/java/com/newscatcher/catchall/resources/jobs/requests/InitializeRequestDto.java b/src/main/java/com/newscatcher/catchall/resources/jobs/requests/InitializeRequestDto.java
index eca197c..af82c3b 100644
--- a/src/main/java/com/newscatcher/catchall/resources/jobs/requests/InitializeRequestDto.java
+++ b/src/main/java/com/newscatcher/catchall/resources/jobs/requests/InitializeRequestDto.java
@@ -13,6 +13,7 @@
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
 import com.newscatcher.catchall.core.ObjectMappers;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 import java.util.Optional;
@@ -25,11 +26,22 @@ public final class InitializeRequestDto {
 
     private final Optional<String> context;
 
+    private final Optional<List<String>> connectedDatasetIds;
+
+    private final Optional<Boolean> fetchAllWatchlistNews;
+
     private final Map<String, Object> additionalProperties;
 
-    private InitializeRequestDto(String query, Optional<String> context, Map<String, Object> additionalProperties) {
+    private InitializeRequestDto(
+            String query,
+            Optional<String> context,
+            Optional<List<String>> connectedDatasetIds,
+            Optional<Boolean> fetchAllWatchlistNews,
+            Map<String, Object> additionalProperties) {
         this.query = query;
         this.context = context;
+        this.connectedDatasetIds = connectedDatasetIds;
+        this.fetchAllWatchlistNews = fetchAllWatchlistNews;
         this.additionalProperties = additionalProperties;
     }
 
@@ -43,6 +55,23 @@ public Optional<String> getContext() {
         return context;
     }
 
+    /**
+     * @return Optional list of watchlist dataset IDs connected to this job.
+     */
+    @JsonProperty("connected_dataset_ids")
+    public Optional<List<String>> getConnectedDatasetIds() {
+        return connectedDatasetIds;
+    }
+
+    /**
+     * @return When true, returns generic news validators and enrichments suitable for
+     * watchlist-based article collection instead of query-specific fields.
+     */
+    @JsonProperty("fetch_all_watchlist_news")
+    public Optional<Boolean> getFetchAllWatchlistNews() {
+        return fetchAllWatchlistNews;
+    }
+
     @java.lang.Override
     public boolean equals(Object other) {
         if (this == other) return true;
@@ -55,12 +84,15 @@ public Map<String, Object> getAdditionalProperties() {
     }
 
     private boolean equalTo(InitializeRequestDto other) {
-        return query.equals(other.query) && context.equals(other.context);
+        return query.equals(other.query)
+                && context.equals(other.context)
+                && connectedDatasetIds.equals(other.connectedDatasetIds)
+                && fetchAllWatchlistNews.equals(other.fetchAllWatchlistNews);
     }
 
     @java.lang.Override
     public int hashCode() {
-        return Objects.hash(this.query, this.context);
+        return Objects.hash(this.query, this.context, this.connectedDatasetIds, this.fetchAllWatchlistNews);
     }
 
     @java.lang.Override
@@ -88,12 +120,31 @@ public interface _FinalStage {
         _FinalStage context(Optional<String> context);
 
         _FinalStage context(String context);
+
+        /**
+         * <p>Optional list of watchlist dataset IDs connected to this job.</p>
+         */
+        _FinalStage connectedDatasetIds(Optional<List<String>> connectedDatasetIds);
+
+        _FinalStage connectedDatasetIds(List<String> connectedDatasetIds);
+
+        /**
+         * <p>When true, returns generic news validators and enrichments suitable for
+         * watchlist-based article collection instead of query-specific fields.</p>
+         */
+        _FinalStage fetchAllWatchlistNews(Optional<Boolean> fetchAllWatchlistNews);
+
+        _FinalStage fetchAllWatchlistNews(Boolean fetchAllWatchlistNews);
     }
 
     @JsonIgnoreProperties(ignoreUnknown = true)
     public static final class Builder implements QueryStage, _FinalStage {
         private String query;
 
+        private Optional<Boolean> fetchAllWatchlistNews = Optional.empty();
+
+        private Optional<List<String>> connectedDatasetIds = Optional.empty();
+
         private Optional<String> context = Optional.empty();
 
         @JsonAnySetter
@@ -105,6 +156,8 @@ private Builder() {}
         public Builder from(InitializeRequestDto other) {
             query(other.getQuery());
             context(other.getContext());
+            connectedDatasetIds(other.getConnectedDatasetIds());
+            fetchAllWatchlistNews(other.getFetchAllWatchlistNews());
             return this;
         }
 
@@ -115,6 +168,48 @@ public _FinalStage query(@NotNull String query) {
             return this;
         }
 
+        /**
+         * <p>When true, returns generic news validators and enrichments suitable for
+         * watchlist-based article collection instead of query-specific fields.</p>
+         * @return Reference to {@code this} so that method calls can be chained together.
+         */
+        @java.lang.Override
+        public _FinalStage fetchAllWatchlistNews(Boolean fetchAllWatchlistNews) {
+            this.fetchAllWatchlistNews = Optional.ofNullable(fetchAllWatchlistNews);
+            return this;
+        }
+
+        /**
+         * <p>When true, returns generic news validators and enrichments suitable for
+         * watchlist-based article collection instead of query-specific fields.</p>
+         */
+        @java.lang.Override
+        @JsonSetter(value = "fetch_all_watchlist_news", nulls = Nulls.SKIP)
+        public _FinalStage fetchAllWatchlistNews(Optional<Boolean> fetchAllWatchlistNews) {
+            this.fetchAllWatchlistNews = fetchAllWatchlistNews;
+            return this;
+        }
+
+        /**
+         * <p>Optional list of watchlist dataset IDs connected to this job.</p>
+         * @return Reference to {@code this} so that method calls can be chained together.
+         */
+        @java.lang.Override
+        public _FinalStage connectedDatasetIds(List<String> connectedDatasetIds) {
+            this.connectedDatasetIds = Optional.ofNullable(connectedDatasetIds);
+            return this;
+        }
+
+        /**
+         * <p>Optional list of watchlist dataset IDs connected to this job.</p>
+         */
+        @java.lang.Override
+        @JsonSetter(value = "connected_dataset_ids", nulls = Nulls.SKIP)
+        public _FinalStage connectedDatasetIds(Optional<List<String>> connectedDatasetIds) {
+            this.connectedDatasetIds = connectedDatasetIds;
+            return this;
+        }
+
         @java.lang.Override
         public _FinalStage context(String context) {
             this.context = Optional.ofNullable(context);
@@ -130,7 +225,8 @@ public _FinalStage context(Optional<String> context) {
 
         @java.lang.Override
         public InitializeRequestDto build() {
-            return new InitializeRequestDto(query, context, additionalProperties);
+            return new InitializeRequestDto(
+                    query, context, connectedDatasetIds, fetchAllWatchlistNews, additionalProperties);
         }
 
         @java.lang.Override
diff --git a/src/main/java/com/newscatcher/catchall/resources/jobs/requests/SubmitRequestDto.java b/src/main/java/com/newscatcher/catchall/resources/jobs/requests/SubmitRequestDto.java
index f6fdfd0..f1549fb 100644
--- a/src/main/java/com/newscatcher/catchall/resources/jobs/requests/SubmitRequestDto.java
+++ b/src/main/java/com/newscatcher/catchall/resources/jobs/requests/SubmitRequestDto.java
@@ -14,6 +14,7 @@
 import com.newscatcher.catchall.core.ObjectMappers;
 import com.newscatcher.catchall.resources.jobs.types.SubmitRequestDtoMode;
 import com.newscatcher.catchall.types.EnrichmentSchema;
+import com.newscatcher.catchall.types.EntityAssociationType;
 import com.newscatcher.catchall.types.ValidatorSchema;
 import java.time.OffsetDateTime;
 import java.util.HashMap;
@@ -50,6 +51,10 @@ public final class SubmitRequestDto {
 
     private final Optional<List<String>> webhookIds;
 
+    private final Optional<Boolean> fetchAllWatchlistNews;
+
+    private final Optional<EntityAssociationType> edAssociationType;
+
     private final Map<String, Object> additionalProperties;
 
     private SubmitRequestDto(
@@ -65,6 +70,8 @@ private SubmitRequestDto(
             Optional<Integer> edScoreMin,
             Optional<String> projectId,
             Optional<List<String>> webhookIds,
+            Optional<Boolean> fetchAllWatchlistNews,
+            Optional<EntityAssociationType> edAssociationType,
             Map<String, Object> additionalProperties) {
         this.query = query;
         this.context = context;
@@ -78,6 +85,8 @@ private SubmitRequestDto(
         this.edScoreMin = edScoreMin;
         this.projectId = projectId;
         this.webhookIds = webhookIds;
+        this.fetchAllWatchlistNews = fetchAllWatchlistNews;
+        this.edAssociationType = edAssociationType;
         this.additionalProperties = additionalProperties;
     }
 
@@ -170,6 +179,26 @@ public Optional<List<String>> getWebhookIds() {
         return webhookIds;
     }
 
+    /**
+     * @return When true, retrieves all news for connected Company Watchlist entities
+     * without topic filtering. Requires connected_dataset_ids to be set.
+     */
+    @JsonProperty("fetch_all_watchlist_news")
+    public Optional<Boolean> getFetchAllWatchlistNews() {
+        return fetchAllWatchlistNews;
+    }
+
+    /**
+     * @return Filter events by entity association type. <code>event_associated</code> keeps only
+     * events where the entity is a direct actor. <code>mention</code> keeps only events
+     * where the entity is merely referenced. Only relevant when
+     * connected_dataset_ids is set.
+     */
+    @JsonProperty("ed_association_type")
+    public Optional<EntityAssociationType> getEdAssociationType() {
+        return edAssociationType;
+    }
+
     @java.lang.Override
     public boolean equals(Object other) {
         if (this == other) return true;
@@ -193,7 +222,9 @@ private boolean equalTo(SubmitRequestDto other) {
                 && connectedDatasetIds.equals(other.connectedDatasetIds)
                 && edScoreMin.equals(other.edScoreMin)
                 && projectId.equals(other.projectId)
-                && webhookIds.equals(other.webhookIds);
+                && webhookIds.equals(other.webhookIds)
+                && fetchAllWatchlistNews.equals(other.fetchAllWatchlistNews)
+                && edAssociationType.equals(other.edAssociationType);
     }
 
     @java.lang.Override
@@ -210,7 +241,9 @@ public int hashCode() {
                 this.connectedDatasetIds,
                 this.edScoreMin,
                 this.projectId,
-                this.webhookIds);
+                this.webhookIds,
+                this.fetchAllWatchlistNews,
+                this.edAssociationType);
     }
 
     @java.lang.Override
@@ -307,12 +340,34 @@ public interface _FinalStage {
         _FinalStage webhookIds(Optional<List<String>> webhookIds);
 
         _FinalStage webhookIds(List<String> webhookIds);
+
+        /**
+         * <p>When true, retrieves all news for connected Company Watchlist entities
+         * without topic filtering. Requires connected_dataset_ids to be set.</p>
+         */
+        _FinalStage fetchAllWatchlistNews(Optional<Boolean> fetchAllWatchlistNews);
+
+        _FinalStage fetchAllWatchlistNews(Boolean fetchAllWatchlistNews);
+
+        /**
+         * <p>Filter events by entity association type. <code>event_associated</code> keeps only
+         * events where the entity is a direct actor. <code>mention</code> keeps only events
+         * where the entity is merely referenced. Only relevant when
+         * connected_dataset_ids is set.</p>
+         */
+        _FinalStage edAssociationType(Optional<EntityAssociationType> edAssociationType);
+
+        _FinalStage edAssociationType(EntityAssociationType edAssociationType);
     }
 
     @JsonIgnoreProperties(ignoreUnknown = true)
     public static final class Builder implements QueryStage, _FinalStage {
         private String query;
 
+        private Optional<EntityAssociationType> edAssociationType = Optional.empty();
+
+        private Optional<Boolean> fetchAllWatchlistNews = Optional.empty();
+
         private Optional<List<String>> webhookIds = Optional.empty();
 
         private Optional<String> projectId = Optional.empty();
@@ -354,6 +409,8 @@ public Builder from(SubmitRequestDto other) {
             edScoreMin(other.getEdScoreMin());
             projectId(other.getProjectId());
             webhookIds(other.getWebhookIds());
+            fetchAllWatchlistNews(other.getFetchAllWatchlistNews());
+            edAssociationType(other.getEdAssociationType());
             return this;
         }
 
@@ -364,6 +421,54 @@ public _FinalStage query(@NotNull String query) {
             return this;
         }
 
+        /**
+         * <p>Filter events by entity association type. <code>event_associated</code> keeps only
+         * events where the entity is a direct actor. <code>mention</code> keeps only events
+         * where the entity is merely referenced. Only relevant when
+         * connected_dataset_ids is set.</p>
+         * @return Reference to {@code this} so that method calls can be chained together.
+         */
+        @java.lang.Override
+        public _FinalStage edAssociationType(EntityAssociationType edAssociationType) {
+            this.edAssociationType = Optional.ofNullable(edAssociationType);
+            return this;
+        }
+
+        /**
+         * <p>Filter events by entity association type. <code>event_associated</code> keeps only
+         * events where the entity is a direct actor. <code>mention</code> keeps only events
+         * where the entity is merely referenced. Only relevant when
+         * connected_dataset_ids is set.</p>
+         */
+        @java.lang.Override
+        @JsonSetter(value = "ed_association_type", nulls = Nulls.SKIP)
+        public _FinalStage edAssociationType(Optional<EntityAssociationType> edAssociationType) {
+            this.edAssociationType = edAssociationType;
+            return this;
+        }
+
+        /**
+         * <p>When true, retrieves all news for connected Company Watchlist entities
+         * without topic filtering. Requires connected_dataset_ids to be set.</p>
+         * @return Reference to {@code this} so that method calls can be chained together.
+         */
+        @java.lang.Override
+        public _FinalStage fetchAllWatchlistNews(Boolean fetchAllWatchlistNews) {
+            this.fetchAllWatchlistNews = Optional.ofNullable(fetchAllWatchlistNews);
+            return this;
+        }
+
+        /**
+         * <p>When true, retrieves all news for connected Company Watchlist entities
+         * without topic filtering. Requires connected_dataset_ids to be set.</p>
+         */
+        @java.lang.Override
+        @JsonSetter(value = "fetch_all_watchlist_news", nulls = Nulls.SKIP)
+        public _FinalStage fetchAllWatchlistNews(Optional<Boolean> fetchAllWatchlistNews) {
+            this.fetchAllWatchlistNews = fetchAllWatchlistNews;
+            return this;
+        }
+
         /**
          * <p>IDs of webhooks to notify when the job completes. Maximum 5 per job.</p>
          * @return Reference to {@code this} so that method calls can be chained together.
@@ -587,6 +692,8 @@ public SubmitRequestDto build() {
                     edScoreMin,
                     projectId,
                     webhookIds,
+                    fetchAllWatchlistNews,
+                    edAssociationType,
                     additionalProperties);
         }
 
diff --git a/src/main/java/com/newscatcher/catchall/types/ConnectedEntity.java b/src/main/java/com/newscatcher/catchall/types/ConnectedEntity.java
index 57f8063..ff6efea 100644
--- a/src/main/java/com/newscatcher/catchall/types/ConnectedEntity.java
+++ b/src/main/java/com/newscatcher/catchall/types/ConnectedEntity.java
@@ -29,6 +29,8 @@ public final class ConnectedEntity {
 
     private final String relation;
 
+    private final Optional<String> associationType;
+
     private final String type;
 
     private final Optional<CompanyAttributes> company;
@@ -40,6 +42,7 @@ private ConnectedEntity(
             String name,
             int edScore,
             String relation,
+            Optional<String> associationType,
             String type,
             Optional<CompanyAttributes> company,
             Map<String, Object> additionalProperties) {
@@ -47,6 +50,7 @@ private ConnectedEntity(
         this.name = name;
         this.edScore = edScore;
         this.relation = relation;
+        this.associationType = associationType;
         this.type = type;
         this.company = company;
         this.additionalProperties = additionalProperties;
@@ -90,6 +94,14 @@ public String getRelation() {
         return relation;
     }
 
+    /**
+     * @return How the entity relates to the event: <code>event_associated</code> if the entity is a direct actor, <code>mention</code> if merely referenced.
+     */
+    @JsonProperty("association_type")
+    public Optional<String> getAssociationType() {
+        return associationType;
+    }
+
     /**
      * @return The entity type.
      */
@@ -123,13 +135,15 @@ private boolean equalTo(ConnectedEntity other) {
                 && name.equals(other.name)
                 && edScore == other.edScore
                 && relation.equals(other.relation)
+                && associationType.equals(other.associationType)
                 && type.equals(other.type)
                 && company.equals(other.company);
     }
 
     @java.lang.Override
     public int hashCode() {
-        return Objects.hash(this.entityId, this.name, this.edScore, this.relation, this.type, this.company);
+        return Objects.hash(
+                this.entityId, this.name, this.edScore, this.relation, this.associationType, this.type, this.company);
     }
 
     @java.lang.Override
@@ -191,6 +205,13 @@ public interface _FinalStage {
 
         _FinalStage additionalProperties(Map<String, Object> additionalProperties);
 
+        /**
+         * <p>How the entity relates to the event: <code>event_associated</code> if the entity is a direct actor, <code>mention</code> if merely referenced.</p>
+         */
+        _FinalStage associationType(Optional<String> associationType);
+
+        _FinalStage associationType(String associationType);
+
         /**
          * <p>The stored attributes for this entity. Present only when attributes exist in the database.</p>
          * <p>The field name matches the value of <code>type</code> — for example, <code>&quot;company&quot;</code> type entities have a <code>company</code>  field.</p>
@@ -215,6 +236,8 @@ public static final class Builder
 
         private Optional<CompanyAttributes> company = Optional.empty();
 
+        private Optional<String> associationType = Optional.empty();
+
         @JsonAnySetter
         private Map<String, Object> additionalProperties = new HashMap<>();
 
@@ -226,6 +249,7 @@ public Builder from(ConnectedEntity other) {
             name(other.getName());
             edScore(other.getEdScore());
             relation(other.getRelation());
+            associationType(other.getAssociationType());
             type(other.getType());
             company(other.getCompany());
             return this;
@@ -325,9 +349,30 @@ public _FinalStage company(Optional<CompanyAttributes> company) {
             return this;
         }
 
+        /**
+         * <p>How the entity relates to the event: <code>event_associated</code> if the entity is a direct actor, <code>mention</code> if merely referenced.</p>
+         * @return Reference to {@code this} so that method calls can be chained together.
+         */
+        @java.lang.Override
+        public _FinalStage associationType(String associationType) {
+            this.associationType = Optional.ofNullable(associationType);
+            return this;
+        }
+
+        /**
+         * <p>How the entity relates to the event: <code>event_associated</code> if the entity is a direct actor, <code>mention</code> if merely referenced.</p>
+         */
+        @java.lang.Override
+        @JsonSetter(value = "association_type", nulls = Nulls.SKIP)
+        public _FinalStage associationType(Optional<String> associationType) {
+            this.associationType = associationType;
+            return this;
+        }
+
         @java.lang.Override
         public ConnectedEntity build() {
-            return new ConnectedEntity(entityId, name, edScore, relation, type, company, additionalProperties);
+            return new ConnectedEntity(
+                    entityId, name, edScore, relation, associationType, type, company, additionalProperties);
         }
 
         @java.lang.Override
diff --git a/src/main/java/com/newscatcher/catchall/types/EntityAssociationType.java b/src/main/java/com/newscatcher/catchall/types/EntityAssociationType.java
new file mode 100644
index 0000000..354c9a5
--- /dev/null
+++ b/src/main/java/com/newscatcher/catchall/types/EntityAssociationType.java
@@ -0,0 +1,85 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.newscatcher.catchall.types;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonValue;
+
+public final class EntityAssociationType {
+    public static final EntityAssociationType EVENT_ASSOCIATED =
+            new EntityAssociationType(Value.EVENT_ASSOCIATED, "event_associated");
+
+    public static final EntityAssociationType MENTION = new EntityAssociationType(Value.MENTION, "mention");
+
+    private final Value value;
+
+    private final String string;
+
+    EntityAssociationType(Value value, String string) {
+        this.value = value;
+        this.string = string;
+    }
+
+    public Value getEnumValue() {
+        return value;
+    }
+
+    @java.lang.Override
+    @JsonValue
+    public String toString() {
+        return this.string;
+    }
+
+    @java.lang.Override
+    public boolean equals(Object other) {
+        return (this == other)
+                || (other instanceof EntityAssociationType
+                        && this.string.equals(((EntityAssociationType) other).string));
+    }
+
+    @java.lang.Override
+    public int hashCode() {
+        return this.string.hashCode();
+    }
+
+    public <T> T visit(Visitor<T> visitor) {
+        switch (value) {
+            case EVENT_ASSOCIATED:
+                return visitor.visitEventAssociated();
+            case MENTION:
+                return visitor.visitMention();
+            case UNKNOWN:
+            default:
+                return visitor.visitUnknown(string);
+        }
+    }
+
+    @JsonCreator(mode = JsonCreator.Mode.DELEGATING)
+    public static EntityAssociationType valueOf(String value) {
+        switch (value) {
+            case "event_associated":
+                return EVENT_ASSOCIATED;
+            case "mention":
+                return MENTION;
+            default:
+                return new EntityAssociationType(Value.UNKNOWN, value);
+        }
+    }
+
+    public enum Value {
+        MENTION,
+
+        EVENT_ASSOCIATED,
+
+        UNKNOWN
+    }
+
+    public interface Visitor<T> {
+        T visitMention();
+
+        T visitEventAssociated();
+
+        T visitUnknown(String unknownType);
+    }
+}