Skip to content
This repository was archived by the owner on May 24, 2024. It is now read-only.

Commit d779941

Browse files
Update commit update event (#70)
* update commit update event Signed-off-by: Ayman <[email protected]> * clean up Signed-off-by: Ayman <[email protected]> Signed-off-by: Ayman <[email protected]> Co-authored-by: Ayman <[email protected]>
1 parent 33c31df commit d779941

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

cmd/git/git.go

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2445,6 +2445,13 @@ func (j *DSGit) Sync(ctx *shared.Ctx) (err error) {
24452445
}
24462446
}
24472447

2448+
var content string
2449+
if len(record) > 7 {
2450+
if record[7] != "" {
2451+
content = record[7]
2452+
}
2453+
}
2454+
24482455
cachedCommits[record[1]] = CommitCache{
24492456
Timestamp: record[0],
24502457
EntityID: record[1],
@@ -2453,7 +2460,7 @@ func (j *DSGit) Sync(ctx *shared.Ctx) (err error) {
24532460
Hash: record[4],
24542461
Orphaned: orphaned,
24552462
FromDL: fromDL,
2456-
Content: record[7],
2463+
Content: content,
24572464
}
24582465
}
24592466
if ctx.DateTo != nil {
@@ -2899,6 +2906,7 @@ func (j *DSGit) handleDataLakeOrphans() {
28992906
j.log.WithFields(logrus.Fields{"operation": "handleDataLakeOrphans"}).Errorf("error unmarshall datalake orphand commit: %+v", err)
29002907
continue
29012908
}
2909+
commit.Orphaned = true
29022910
commitEvent := git.CommitUpdatedEvent{
29032911
CommitBaseEvent: commitBaseEvent,
29042912
BaseEvent: baseEvent,

0 commit comments

Comments
 (0)