diff --git a/pipeline/pipeline.proto b/pipeline/pipeline.proto
index e9a43524..d366e374 100644
--- a/pipeline/pipeline.proto
+++ b/pipeline/pipeline.proto
@@ -58,7 +58,13 @@ service Pipeline {
       delete: "/pipelines/{name}"
     };
   }
-  rpc TriggerPipelineByUpload (stream TriggerPipelineRequest) returns (google.protobuf.Struct) {
+  rpc TriggerPipeline (TriggerPipelineRequest) returns (google.protobuf.Struct) {
+    option (google.api.http) = {
+      post: "/pipelines/{name}/outputs"
+      body: "*"
+    };
+  }
+  rpc TriggerPipelineByUpload (stream TriggerPipelineImageRequest) returns (google.protobuf.Struct) {
   }
 }
 
@@ -114,7 +120,6 @@ message DeletePipelineRequest {
 message TriggerPipelineContent {
   string url = 1 [(google.api.field_behavior) = OPTIONAL];
   string base64 = 2 [(google.api.field_behavior) = OPTIONAL];
-  bytes chunk = 3 [(google.api.field_behavior) = OPTIONAL];
 }
 
 message TriggerPipelineRequest {
@@ -122,6 +127,15 @@ message TriggerPipelineRequest {
   repeated TriggerPipelineContent contents = 2 [(google.api.field_behavior) = REQUIRED];
 }
 
+message TriggerPipelineImageContent {
+  bytes chunk = 1 [(google.api.field_behavior) = REQUIRED];
+}
+
+message TriggerPipelineImageRequest {
+  string name = 1 [(google.api.field_behavior) = REQUIRED];
+  repeated TriggerPipelineImageContent contents = 2 [(google.api.field_behavior) = REQUIRED];
+}
+
 message Scheduler {
   string crontab = 1 [(google.api.field_behavior) = REQUIRED];
 }