diff --git a/lib/src/gen/app/datapipelines/v1/data_pipelines.pb.dart b/lib/src/gen/app/datapipelines/v1/data_pipelines.pb.dart
index 067a59b2bd4..737cac20d92 100644
--- a/lib/src/gen/app/datapipelines/v1/data_pipelines.pb.dart
+++ b/lib/src/gen/app/datapipelines/v1/data_pipelines.pb.dart
@@ -210,6 +210,7 @@ class GetDataPipelineRequest extends $pb.GeneratedMessage {
   static GetDataPipelineRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<GetDataPipelineRequest>(create);
   static GetDataPipelineRequest? _defaultInstance;
 
+  /// The ID of the data pipeline to retrieve.
   @$pb.TagNumber(1)
   $core.String get id => $_getSZ(0);
   @$pb.TagNumber(1)
@@ -312,6 +313,7 @@ class ListDataPipelinesRequest extends $pb.GeneratedMessage {
   static ListDataPipelinesRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<ListDataPipelinesRequest>(create);
   static ListDataPipelinesRequest? _defaultInstance;
 
+  /// The associated Viam organization ID.
   @$pb.TagNumber(1)
   $core.String get organizationId => $_getSZ(0);
   @$pb.TagNumber(1)
@@ -368,11 +370,23 @@ class ListDataPipelinesResponse extends $pb.GeneratedMessage {
 
 class CreateDataPipelineRequest extends $pb.GeneratedMessage {
   factory CreateDataPipelineRequest({
-    DataPipeline? dataPipeline,
+    $core.String? organizationId,
+    $core.String? name,
+    $core.Iterable<$core.List<$core.int>>? mqlBinary,
+    $core.String? schedule,
   }) {
     final $result = create();
-    if (dataPipeline != null) {
-      $result.dataPipeline = dataPipeline;
+    if (organizationId != null) {
+      $result.organizationId = organizationId;
+    }
+    if (name != null) {
+      $result.name = name;
+    }
+    if (mqlBinary != null) {
+      $result.mqlBinary.addAll(mqlBinary);
+    }
+    if (schedule != null) {
+      $result.schedule = schedule;
     }
     return $result;
   }
@@ -381,7 +395,10 @@ class CreateDataPipelineRequest extends $pb.GeneratedMessage {
   factory CreateDataPipelineRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
 
   static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'CreateDataPipelineRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'viam.app.datapipelines.v1'), createEmptyInstance: create)
-    ..aOM<DataPipeline>(1, _omitFieldNames ? '' : 'dataPipeline', subBuilder: DataPipeline.create)
+    ..aOS(1, _omitFieldNames ? '' : 'organizationId')
+    ..aOS(2, _omitFieldNames ? '' : 'name')
+    ..p<$core.List<$core.int>>(3, _omitFieldNames ? '' : 'mqlBinary', $pb.PbFieldType.PY)
+    ..aOS(4, _omitFieldNames ? '' : 'schedule')
     ..hasRequiredFields = false
   ;
 
@@ -406,16 +423,41 @@ class CreateDataPipelineRequest extends $pb.GeneratedMessage {
   static CreateDataPipelineRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<CreateDataPipelineRequest>(create);
   static CreateDataPipelineRequest? _defaultInstance;
 
+  /// The associated Viam organization ID.
   @$pb.TagNumber(1)
-  DataPipeline get dataPipeline => $_getN(0);
-  @$pb.TagNumber(1)
-  set dataPipeline(DataPipeline v) { setField(1, v); }
+  $core.String get organizationId => $_getSZ(0);
   @$pb.TagNumber(1)
-  $core.bool hasDataPipeline() => $_has(0);
+  set organizationId($core.String v) { $_setString(0, v); }
   @$pb.TagNumber(1)
-  void clearDataPipeline() => clearField(1);
+  $core.bool hasOrganizationId() => $_has(0);
   @$pb.TagNumber(1)
-  DataPipeline ensureDataPipeline() => $_ensure(0);
+  void clearOrganizationId() => clearField(1);
+
+  /// A unique identifier at the org level.
+  @$pb.TagNumber(2)
+  $core.String get name => $_getSZ(1);
+  @$pb.TagNumber(2)
+  set name($core.String v) { $_setString(1, v); }
+  @$pb.TagNumber(2)
+  $core.bool hasName() => $_has(1);
+  @$pb.TagNumber(2)
+  void clearName() => clearField(2);
+
+  /// A MongoDB aggregation pipeline as a list of BSON documents, where
+  /// each document is one stage in the pipeline.
+  @$pb.TagNumber(3)
+  $core.List<$core.List<$core.int>> get mqlBinary => $_getList(2);
+
+  /// A cron expression representing the expected execution schedule in UTC (note this also
+  /// defines the input time window; an hourly schedule would process 1 hour of data at a time).
+  @$pb.TagNumber(4)
+  $core.String get schedule => $_getSZ(3);
+  @$pb.TagNumber(4)
+  set schedule($core.String v) { $_setString(3, v); }
+  @$pb.TagNumber(4)
+  $core.bool hasSchedule() => $_has(3);
+  @$pb.TagNumber(4)
+  void clearSchedule() => clearField(4);
 }
 
 class CreateDataPipelineResponse extends $pb.GeneratedMessage {
@@ -458,6 +500,7 @@ class CreateDataPipelineResponse extends $pb.GeneratedMessage {
   static CreateDataPipelineResponse getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<CreateDataPipelineResponse>(create);
   static CreateDataPipelineResponse? _defaultInstance;
 
+  /// The ID of the newly created data pipeline.
   @$pb.TagNumber(1)
   $core.String get id => $_getSZ(0);
   @$pb.TagNumber(1)
@@ -471,14 +514,26 @@ class CreateDataPipelineResponse extends $pb.GeneratedMessage {
 class UpdateDataPipelineRequest extends $pb.GeneratedMessage {
   factory UpdateDataPipelineRequest({
     $core.String? id,
-    DataPipeline? dataPipeline,
+    $core.String? name,
+    $core.Iterable<$core.List<$core.int>>? mqlBinary,
+    $core.String? schedule,
+    $core.bool? enabled,
   }) {
     final $result = create();
     if (id != null) {
       $result.id = id;
     }
-    if (dataPipeline != null) {
-      $result.dataPipeline = dataPipeline;
+    if (name != null) {
+      $result.name = name;
+    }
+    if (mqlBinary != null) {
+      $result.mqlBinary.addAll(mqlBinary);
+    }
+    if (schedule != null) {
+      $result.schedule = schedule;
+    }
+    if (enabled != null) {
+      $result.enabled = enabled;
     }
     return $result;
   }
@@ -488,7 +543,10 @@ class UpdateDataPipelineRequest extends $pb.GeneratedMessage {
 
   static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'UpdateDataPipelineRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'viam.app.datapipelines.v1'), createEmptyInstance: create)
     ..aOS(1, _omitFieldNames ? '' : 'id')
-    ..aOM<DataPipeline>(2, _omitFieldNames ? '' : 'dataPipeline', subBuilder: DataPipeline.create)
+    ..aOS(2, _omitFieldNames ? '' : 'name')
+    ..p<$core.List<$core.int>>(3, _omitFieldNames ? '' : 'mqlBinary', $pb.PbFieldType.PY)
+    ..aOS(4, _omitFieldNames ? '' : 'schedule')
+    ..aOB(5, _omitFieldNames ? '' : 'enabled')
     ..hasRequiredFields = false
   ;
 
@@ -513,6 +571,7 @@ class UpdateDataPipelineRequest extends $pb.GeneratedMessage {
   static UpdateDataPipelineRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<UpdateDataPipelineRequest>(create);
   static UpdateDataPipelineRequest? _defaultInstance;
 
+  /// The ID of the data pipeline to update.
   @$pb.TagNumber(1)
   $core.String get id => $_getSZ(0);
   @$pb.TagNumber(1)
@@ -522,34 +581,50 @@ class UpdateDataPipelineRequest extends $pb.GeneratedMessage {
   @$pb.TagNumber(1)
   void clearId() => clearField(1);
 
+  /// A unique identifier at the org level.
   @$pb.TagNumber(2)
-  DataPipeline get dataPipeline => $_getN(1);
-  @$pb.TagNumber(2)
-  set dataPipeline(DataPipeline v) { setField(2, v); }
+  $core.String get name => $_getSZ(1);
   @$pb.TagNumber(2)
-  $core.bool hasDataPipeline() => $_has(1);
+  set name($core.String v) { $_setString(1, v); }
   @$pb.TagNumber(2)
-  void clearDataPipeline() => clearField(2);
+  $core.bool hasName() => $_has(1);
   @$pb.TagNumber(2)
-  DataPipeline ensureDataPipeline() => $_ensure(1);
+  void clearName() => clearField(2);
+
+  /// A MongoDB aggregation pipeline as a list of BSON documents, where
+  /// each document is one stage in the pipeline.
+  @$pb.TagNumber(3)
+  $core.List<$core.List<$core.int>> get mqlBinary => $_getList(2);
+
+  /// A cron expression representing the expected execution schedule in UTC (note this also
+  /// defines the input time window; an hourly schedule would process 1 hour of data at a time).
+  @$pb.TagNumber(4)
+  $core.String get schedule => $_getSZ(3);
+  @$pb.TagNumber(4)
+  set schedule($core.String v) { $_setString(3, v); }
+  @$pb.TagNumber(4)
+  $core.bool hasSchedule() => $_has(3);
+  @$pb.TagNumber(4)
+  void clearSchedule() => clearField(4);
+
+  /// Whether or not the pipeline is enabled.
+  @$pb.TagNumber(5)
+  $core.bool get enabled => $_getBF(4);
+  @$pb.TagNumber(5)
+  set enabled($core.bool v) { $_setBool(4, v); }
+  @$pb.TagNumber(5)
+  $core.bool hasEnabled() => $_has(4);
+  @$pb.TagNumber(5)
+  void clearEnabled() => clearField(5);
 }
 
 class UpdateDataPipelineResponse extends $pb.GeneratedMessage {
-  factory UpdateDataPipelineResponse({
-    $core.String? id,
-  }) {
-    final $result = create();
-    if (id != null) {
-      $result.id = id;
-    }
-    return $result;
-  }
+  factory UpdateDataPipelineResponse() => create();
   UpdateDataPipelineResponse._() : super();
   factory UpdateDataPipelineResponse.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
   factory UpdateDataPipelineResponse.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
 
   static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'UpdateDataPipelineResponse', package: const $pb.PackageName(_omitMessageNames ? '' : 'viam.app.datapipelines.v1'), createEmptyInstance: create)
-    ..aOS(1, _omitFieldNames ? '' : 'id')
     ..hasRequiredFields = false
   ;
 
@@ -573,15 +648,6 @@ class UpdateDataPipelineResponse extends $pb.GeneratedMessage {
   @$core.pragma('dart2js:noInline')
   static UpdateDataPipelineResponse getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<UpdateDataPipelineResponse>(create);
   static UpdateDataPipelineResponse? _defaultInstance;
-
-  @$pb.TagNumber(1)
-  $core.String get id => $_getSZ(0);
-  @$pb.TagNumber(1)
-  set id($core.String v) { $_setString(0, v); }
-  @$pb.TagNumber(1)
-  $core.bool hasId() => $_has(0);
-  @$pb.TagNumber(1)
-  void clearId() => clearField(1);
 }
 
 class DeleteDataPipelineRequest extends $pb.GeneratedMessage {
@@ -624,6 +690,7 @@ class DeleteDataPipelineRequest extends $pb.GeneratedMessage {
   static DeleteDataPipelineRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<DeleteDataPipelineRequest>(create);
   static DeleteDataPipelineRequest? _defaultInstance;
 
+  /// The ID of the data pipeline to delete.
   @$pb.TagNumber(1)
   $core.String get id => $_getSZ(0);
   @$pb.TagNumber(1)
diff --git a/lib/src/gen/app/datapipelines/v1/data_pipelines.pbjson.dart b/lib/src/gen/app/datapipelines/v1/data_pipelines.pbjson.dart
index a972bdf2aed..d7835789802 100644
--- a/lib/src/gen/app/datapipelines/v1/data_pipelines.pbjson.dart
+++ b/lib/src/gen/app/datapipelines/v1/data_pipelines.pbjson.dart
@@ -92,14 +92,18 @@ final $typed_data.Uint8List listDataPipelinesResponseDescriptor = $convert.base6
 const CreateDataPipelineRequest$json = {
   '1': 'CreateDataPipelineRequest',
   '2': [
-    {'1': 'data_pipeline', '3': 1, '4': 1, '5': 11, '6': '.viam.app.datapipelines.v1.DataPipeline', '10': 'dataPipeline'},
+    {'1': 'organization_id', '3': 1, '4': 1, '5': 9, '10': 'organizationId'},
+    {'1': 'name', '3': 2, '4': 1, '5': 9, '10': 'name'},
+    {'1': 'mql_binary', '3': 3, '4': 3, '5': 12, '10': 'mqlBinary'},
+    {'1': 'schedule', '3': 4, '4': 1, '5': 9, '10': 'schedule'},
   ],
 };
 
 /// Descriptor for `CreateDataPipelineRequest`. Decode as a `google.protobuf.DescriptorProto`.
 final $typed_data.Uint8List createDataPipelineRequestDescriptor = $convert.base64Decode(
-    'ChlDcmVhdGVEYXRhUGlwZWxpbmVSZXF1ZXN0EkwKDWRhdGFfcGlwZWxpbmUYASABKAsyJy52aW'
-    'FtLmFwcC5kYXRhcGlwZWxpbmVzLnYxLkRhdGFQaXBlbGluZVIMZGF0YVBpcGVsaW5l');
+    'ChlDcmVhdGVEYXRhUGlwZWxpbmVSZXF1ZXN0EicKD29yZ2FuaXphdGlvbl9pZBgBIAEoCVIOb3'
+    'JnYW5pemF0aW9uSWQSEgoEbmFtZRgCIAEoCVIEbmFtZRIdCgptcWxfYmluYXJ5GAMgAygMUglt'
+    'cWxCaW5hcnkSGgoIc2NoZWR1bGUYBCABKAlSCHNjaGVkdWxl');
 
 @$core.Deprecated('Use createDataPipelineResponseDescriptor instead')
 const CreateDataPipelineResponse$json = {
@@ -118,27 +122,27 @@ const UpdateDataPipelineRequest$json = {
   '1': 'UpdateDataPipelineRequest',
   '2': [
     {'1': 'id', '3': 1, '4': 1, '5': 9, '10': 'id'},
-    {'1': 'data_pipeline', '3': 2, '4': 1, '5': 11, '6': '.viam.app.datapipelines.v1.DataPipeline', '10': 'dataPipeline'},
+    {'1': 'name', '3': 2, '4': 1, '5': 9, '10': 'name'},
+    {'1': 'mql_binary', '3': 3, '4': 3, '5': 12, '10': 'mqlBinary'},
+    {'1': 'schedule', '3': 4, '4': 1, '5': 9, '10': 'schedule'},
+    {'1': 'enabled', '3': 5, '4': 1, '5': 8, '10': 'enabled'},
   ],
 };
 
 /// Descriptor for `UpdateDataPipelineRequest`. Decode as a `google.protobuf.DescriptorProto`.
 final $typed_data.Uint8List updateDataPipelineRequestDescriptor = $convert.base64Decode(
-    'ChlVcGRhdGVEYXRhUGlwZWxpbmVSZXF1ZXN0Eg4KAmlkGAEgASgJUgJpZBJMCg1kYXRhX3BpcG'
-    'VsaW5lGAIgASgLMicudmlhbS5hcHAuZGF0YXBpcGVsaW5lcy52MS5EYXRhUGlwZWxpbmVSDGRh'
-    'dGFQaXBlbGluZQ==');
+    'ChlVcGRhdGVEYXRhUGlwZWxpbmVSZXF1ZXN0Eg4KAmlkGAEgASgJUgJpZBISCgRuYW1lGAIgAS'
+    'gJUgRuYW1lEh0KCm1xbF9iaW5hcnkYAyADKAxSCW1xbEJpbmFyeRIaCghzY2hlZHVsZRgEIAEo'
+    'CVIIc2NoZWR1bGUSGAoHZW5hYmxlZBgFIAEoCFIHZW5hYmxlZA==');
 
 @$core.Deprecated('Use updateDataPipelineResponseDescriptor instead')
 const UpdateDataPipelineResponse$json = {
   '1': 'UpdateDataPipelineResponse',
-  '2': [
-    {'1': 'id', '3': 1, '4': 1, '5': 9, '10': 'id'},
-  ],
 };
 
 /// Descriptor for `UpdateDataPipelineResponse`. Decode as a `google.protobuf.DescriptorProto`.
 final $typed_data.Uint8List updateDataPipelineResponseDescriptor = $convert.base64Decode(
-    'ChpVcGRhdGVEYXRhUGlwZWxpbmVSZXNwb25zZRIOCgJpZBgBIAEoCVICaWQ=');
+    'ChpVcGRhdGVEYXRhUGlwZWxpbmVSZXNwb25zZQ==');
 
 @$core.Deprecated('Use deleteDataPipelineRequestDescriptor instead')
 const DeleteDataPipelineRequest$json = {
diff --git a/lib/src/gen/app/v1/app.pb.dart b/lib/src/gen/app/v1/app.pb.dart
index ea75fe8cab0..02f84a81289 100644
--- a/lib/src/gen/app/v1/app.pb.dart
+++ b/lib/src/gen/app/v1/app.pb.dart
@@ -15427,11 +15427,15 @@ class GetAppContentRequest extends $pb.GeneratedMessage {
 
 class GetAppContentResponse extends $pb.GeneratedMessage {
   factory GetAppContentResponse({
-    $core.String? url,
+    $core.String? blobPath,
+    $core.String? entrypoint,
   }) {
     final $result = create();
-    if (url != null) {
-      $result.url = url;
+    if (blobPath != null) {
+      $result.blobPath = blobPath;
+    }
+    if (entrypoint != null) {
+      $result.entrypoint = entrypoint;
     }
     return $result;
   }
@@ -15440,7 +15444,8 @@ class GetAppContentResponse extends $pb.GeneratedMessage {
   factory GetAppContentResponse.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
 
   static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'GetAppContentResponse', package: const $pb.PackageName(_omitMessageNames ? '' : 'viam.app.v1'), createEmptyInstance: create)
-    ..aOS(1, _omitFieldNames ? '' : 'url')
+    ..aOS(1, _omitFieldNames ? '' : 'blobPath')
+    ..aOS(2, _omitFieldNames ? '' : 'entrypoint')
     ..hasRequiredFields = false
   ;
 
@@ -15466,13 +15471,22 @@ class GetAppContentResponse extends $pb.GeneratedMessage {
   static GetAppContentResponse? _defaultInstance;
 
   @$pb.TagNumber(1)
-  $core.String get url => $_getSZ(0);
+  $core.String get blobPath => $_getSZ(0);
   @$pb.TagNumber(1)
-  set url($core.String v) { $_setString(0, v); }
+  set blobPath($core.String v) { $_setString(0, v); }
   @$pb.TagNumber(1)
-  $core.bool hasUrl() => $_has(0);
+  $core.bool hasBlobPath() => $_has(0);
   @$pb.TagNumber(1)
-  void clearUrl() => clearField(1);
+  void clearBlobPath() => clearField(1);
+
+  @$pb.TagNumber(2)
+  $core.String get entrypoint => $_getSZ(1);
+  @$pb.TagNumber(2)
+  set entrypoint($core.String v) { $_setString(1, v); }
+  @$pb.TagNumber(2)
+  $core.bool hasEntrypoint() => $_has(1);
+  @$pb.TagNumber(2)
+  void clearEntrypoint() => clearField(2);
 }
 
 class OrganizationSetLogoRequest extends $pb.GeneratedMessage {
diff --git a/lib/src/gen/app/v1/app.pbjson.dart b/lib/src/gen/app/v1/app.pbjson.dart
index 1ff1db520e7..0c1cfee5b53 100644
--- a/lib/src/gen/app/v1/app.pbjson.dart
+++ b/lib/src/gen/app/v1/app.pbjson.dart
@@ -3756,13 +3756,15 @@ final $typed_data.Uint8List getAppContentRequestDescriptor = $convert.base64Deco
 const GetAppContentResponse$json = {
   '1': 'GetAppContentResponse',
   '2': [
-    {'1': 'url', '3': 1, '4': 1, '5': 9, '10': 'url'},
+    {'1': 'blob_path', '3': 1, '4': 1, '5': 9, '10': 'blobPath'},
+    {'1': 'entrypoint', '3': 2, '4': 1, '5': 9, '10': 'entrypoint'},
   ],
 };
 
 /// Descriptor for `GetAppContentResponse`. Decode as a `google.protobuf.DescriptorProto`.
 final $typed_data.Uint8List getAppContentResponseDescriptor = $convert.base64Decode(
-    'ChVHZXRBcHBDb250ZW50UmVzcG9uc2USEAoDdXJsGAEgASgJUgN1cmw=');
+    'ChVHZXRBcHBDb250ZW50UmVzcG9uc2USGwoJYmxvYl9wYXRoGAEgASgJUghibG9iUGF0aBIeCg'
+    'plbnRyeXBvaW50GAIgASgJUgplbnRyeXBvaW50');
 
 @$core.Deprecated('Use organizationSetLogoRequestDescriptor instead')
 const OrganizationSetLogoRequest$json = {
diff --git a/lib/src/utils.dart b/lib/src/utils.dart
index f58f2b61e62..2383c9b24d5 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.3.0';
-  const String apiTag = 'v0.1.411';
+  const String apiTag = 'v0.1.413';
 
   return 'flutter;$sdkVersion;$apiTag';
 }