diff --git a/lib/src/gen/app/data/v1/data.pb.dart b/lib/src/gen/app/data/v1/data.pb.dart
index 724435cbda4..f0dcc34d38c 100644
--- a/lib/src/gen/app/data/v1/data.pb.dart
+++ b/lib/src/gen/app/data/v1/data.pb.dart
@@ -1055,6 +1055,7 @@ class TabularDataByMQLRequest extends $pb.GeneratedMessage {
     $core.String? organizationId,
     $core.Iterable<$core.List<$core.int>>? mqlBinary,
     $core.bool? useRecentData,
+    $core.String? useDataPipeline,
   }) {
     final $result = create();
     if (organizationId != null) {
@@ -1066,6 +1067,9 @@ class TabularDataByMQLRequest extends $pb.GeneratedMessage {
     if (useRecentData != null) {
       $result.useRecentData = useRecentData;
     }
+    if (useDataPipeline != null) {
+      $result.useDataPipeline = useDataPipeline;
+    }
     return $result;
   }
   TabularDataByMQLRequest._() : super();
@@ -1076,6 +1080,7 @@ class TabularDataByMQLRequest extends $pb.GeneratedMessage {
     ..aOS(1, _omitFieldNames ? '' : 'organizationId')
     ..p<$core.List<$core.int>>(3, _omitFieldNames ? '' : 'mqlBinary', $pb.PbFieldType.PY)
     ..aOB(4, _omitFieldNames ? '' : 'useRecentData')
+    ..aOS(5, _omitFieldNames ? '' : 'useDataPipeline')
     ..hasRequiredFields = false
   ;
 
@@ -1123,6 +1128,17 @@ class TabularDataByMQLRequest extends $pb.GeneratedMessage {
   $core.bool hasUseRecentData() => $_has(2);
   @$pb.TagNumber(4)
   void clearUseRecentData() => clearField(4);
+
+  /// if set, MQL query will target the sink collection for the data pipeline name
+  /// referenced by this value under the given organization.
+  @$pb.TagNumber(5)
+  $core.String get useDataPipeline => $_getSZ(3);
+  @$pb.TagNumber(5)
+  set useDataPipeline($core.String v) { $_setString(3, v); }
+  @$pb.TagNumber(5)
+  $core.bool hasUseDataPipeline() => $_has(3);
+  @$pb.TagNumber(5)
+  void clearUseDataPipeline() => clearField(5);
 }
 
 /// TabularDataByMQLResponse provides unified tabular data and metadata, queried with MQL.
diff --git a/lib/src/gen/app/data/v1/data.pbjson.dart b/lib/src/gen/app/data/v1/data.pbjson.dart
index c9bde0a5e20..b8917943dd4 100644
--- a/lib/src/gen/app/data/v1/data.pbjson.dart
+++ b/lib/src/gen/app/data/v1/data.pbjson.dart
@@ -275,9 +275,11 @@ const TabularDataByMQLRequest$json = {
     {'1': 'organization_id', '3': 1, '4': 1, '5': 9, '10': 'organizationId'},
     {'1': 'mql_binary', '3': 3, '4': 3, '5': 12, '10': 'mqlBinary'},
     {'1': 'use_recent_data', '3': 4, '4': 1, '5': 8, '9': 0, '10': 'useRecentData', '17': true},
+    {'1': 'use_data_pipeline', '3': 5, '4': 1, '5': 9, '9': 1, '10': 'useDataPipeline', '17': true},
   ],
   '8': [
     {'1': '_use_recent_data'},
+    {'1': '_use_data_pipeline'},
   ],
   '9': [
     {'1': 2, '2': 3},
@@ -289,8 +291,9 @@ const TabularDataByMQLRequest$json = {
 final $typed_data.Uint8List tabularDataByMQLRequestDescriptor = $convert.base64Decode(
     'ChdUYWJ1bGFyRGF0YUJ5TVFMUmVxdWVzdBInCg9vcmdhbml6YXRpb25faWQYASABKAlSDm9yZ2'
     'FuaXphdGlvbklkEh0KCm1xbF9iaW5hcnkYAyADKAxSCW1xbEJpbmFyeRIrCg91c2VfcmVjZW50'
-    'X2RhdGEYBCABKAhIAFINdXNlUmVjZW50RGF0YYgBAUISChBfdXNlX3JlY2VudF9kYXRhSgQIAh'
-    'ADUgltcWxfcXVlcnk=');
+    'X2RhdGEYBCABKAhIAFINdXNlUmVjZW50RGF0YYgBARIvChF1c2VfZGF0YV9waXBlbGluZRgFIA'
+    'EoCUgBUg91c2VEYXRhUGlwZWxpbmWIAQFCEgoQX3VzZV9yZWNlbnRfZGF0YUIUChJfdXNlX2Rh'
+    'dGFfcGlwZWxpbmVKBAgCEANSCW1xbF9xdWVyeQ==');
 
 @$core.Deprecated('Use tabularDataByMQLResponseDescriptor instead')
 const TabularDataByMQLResponse$json = {
diff --git a/lib/src/utils.dart b/lib/src/utils.dart
index 6de9c0a751d..32ef3b2583e 100644
--- a/lib/src/utils.dart
+++ b/lib/src/utils.dart
@@ -117,7 +117,7 @@ extension GetReadingsResponseUtils on GetReadingsResponse {
 
 String getVersionMetadata() {
   const String sdkVersion = 'v0.4.0';
-  const String apiTag = 'v0.1.413';
+  const String apiTag = 'v0.1.414';
 
   return 'flutter;$sdkVersion;$apiTag';
 }