Skip to content

Commit

Permalink
delta added/updated split
Browse files Browse the repository at this point in the history
  • Loading branch information
dwsutherland committed Apr 3, 2020
1 parent cfa7734 commit a321b56
Show file tree
Hide file tree
Showing 13 changed files with 495 additions and 315 deletions.
63 changes: 38 additions & 25 deletions cylc/flow/data_messages.proto
Original file line number Diff line number Diff line change
Expand Up @@ -238,57 +238,70 @@ message PbEntireWorkflow {
message EDeltas {
double time = 1;
int64 checksum = 2;
repeated string pruned = 3;
repeated PbEdge deltas = 4;
bool reloaded = 5;
repeated PbEdge added = 3;
repeated PbEdge updated = 4;
repeated string pruned = 5;
bool reloaded = 6;
}

message FDeltas {
double time = 1;
int64 checksum = 2;
repeated string pruned = 3;
repeated PbFamily deltas = 4;
bool reloaded = 5;
repeated PbFamily added = 3;
repeated PbFamily updated = 4;
repeated string pruned = 5;
bool reloaded = 6;
}

message FPDeltas {
double time = 1;
int64 checksum = 2;
repeated string pruned = 3;
repeated PbFamilyProxy deltas = 4;
bool reloaded = 5;
repeated PbFamilyProxy added = 3;
repeated PbFamilyProxy updated = 4;
repeated string pruned = 5;
bool reloaded = 6;
}

message JDeltas {
double time = 1;
int64 checksum = 2;
repeated string pruned = 3;
repeated PbJob deltas = 4;
bool reloaded = 5;
repeated PbJob added = 3;
repeated PbJob updated = 4;
repeated string pruned = 5;
bool reloaded = 6;
}

message TDeltas {
double time = 1;
int64 checksum = 2;
repeated string pruned = 3;
repeated PbTask deltas = 4;
bool reloaded = 5;
repeated PbTask added = 3;
repeated PbTask updated = 4;
repeated string pruned = 5;
bool reloaded = 6;
}

message TPDeltas {
double time = 1;
int64 checksum = 2;
repeated string pruned = 3;
repeated PbTaskProxy deltas = 4;
bool reloaded = 5;
repeated PbTaskProxy added = 3;
repeated PbTaskProxy updated = 4;
repeated string pruned = 5;
bool reloaded = 6;
}

message WDeltas {
double time = 1;
PbWorkflow added = 2;
PbWorkflow updated = 3;
bool reloaded = 4;
}

message AllDeltas {
PbWorkflow workflow = 1;
EDeltas edges = 2;
FDeltas families = 3;
FPDeltas family_proxies = 4;
JDeltas jobs = 5;
TDeltas tasks = 6;
TPDeltas task_proxies = 7;
FDeltas families = 1;
FPDeltas family_proxies = 2;
JDeltas jobs = 3;
TDeltas tasks = 4;
TPDeltas task_proxies = 5;
EDeltas edges = 6;
WDeltas workflow = 7;
}
228 changes: 169 additions & 59 deletions cylc/flow/data_messages_pb2.py

Large diffs are not rendered by default.

Loading

0 comments on commit a321b56

Please sign in to comment.