Skip to content

Commit 4c64adb

Browse files
authored
Added selfstream flag to stream request so correct command is executed (#1389)
1 parent 869c152 commit 4c64adb

File tree

4 files changed

+154
-619
lines changed

4 files changed

+154
-619
lines changed

api/worker_grpc.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -704,6 +704,7 @@ func CreateStreamRequest(daoWrapper dao.DaoWrapper, stream model.Stream, course
704704
StreamName: slot.StreamName,
705705
IngestServer: server.Url,
706706
OutUrl: server.OutUrl,
707+
SelfStream: stream.IsSelfStream(),
707708
}
708709
workerIndex := getWorkerWithLeastWorkload(workers)
709710
workers[workerIndex].Workload += 3

worker/api/api.proto

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,7 @@ message StreamRequest {
9090
string StreamName = 13;
9191
string IngestServer = 14;
9292
string OutUrl = 15;
93+
bool SelfStream = 16;
9394
}
9495

9596
message PremiereRequest {

0 commit comments

Comments
 (0)