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 Mar 10, 2020
1 parent 411bbc4 commit a9277b5
Show file tree
Hide file tree
Showing 12 changed files with 490 additions and 312 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 a9277b5

Please sign in to comment.