@@ -18,7 +18,7 @@ class AuditClientListener @Inject constructor(
18
18
override fun runStarted (id : Id <DbBackfillRun >, user : String ) {
19
19
val (backfillName, run, description) = transacter.transaction { session ->
20
20
val run = session.load<DbBackfillRun >(id)
21
- Triple (run.registered_backfill.name, run, " Backfill started by $user ${dryRunPrefix(run)}${nameAndId(run)} " )
21
+ AuditEvent (run.registered_backfill.name, run, " Backfill started by $user ${dryRunPrefix(run)}${nameAndId(run)} " )
22
22
}
23
23
auditClient.logEvent(
24
24
target = backfillName,
@@ -32,7 +32,7 @@ class AuditClientListener @Inject constructor(
32
32
override fun runPaused (id : Id <DbBackfillRun >, user : String ) {
33
33
val (backfillName, run, description) = transacter.transaction { session ->
34
34
val run = session.load<DbBackfillRun >(id)
35
- Triple (run.registered_backfill.name, run, " Backfill paused by $user ${dryRunPrefix(run)}${nameAndId(run)} " )
35
+ AuditEvent (run.registered_backfill.name, run, " Backfill paused by $user ${dryRunPrefix(run)}${nameAndId(run)} " )
36
36
}
37
37
auditClient.logEvent(
38
38
target = backfillName,
@@ -46,7 +46,7 @@ class AuditClientListener @Inject constructor(
46
46
override fun runErrored (id : Id <DbBackfillRun >) {
47
47
val (backfillName, run, description) = transacter.transaction { session ->
48
48
val run = session.load<DbBackfillRun >(id)
49
- Triple (run.registered_backfill.name, run, " Backfill paused due to error ${dryRunPrefix(run)}${nameAndId(run)} " )
49
+ AuditEvent (run.registered_backfill.name, run, " Backfill paused due to error ${dryRunPrefix(run)}${nameAndId(run)} " )
50
50
}
51
51
auditClient.logEvent(
52
52
target = backfillName,
@@ -60,7 +60,7 @@ class AuditClientListener @Inject constructor(
60
60
override fun runCompleted (id : Id <DbBackfillRun >) {
61
61
val (backfillName, run, description) = transacter.transaction { session ->
62
62
val run = session.load<DbBackfillRun >(id)
63
- Triple (run.registered_backfill.name, run, " Backfill completed ${dryRunPrefix(run)}${nameAndId(run)} " )
63
+ AuditEvent (run.registered_backfill.name, run, " Backfill completed ${dryRunPrefix(run)}${nameAndId(run)} " )
64
64
}
65
65
auditClient.logEvent(
66
66
target = backfillName,
@@ -93,4 +93,10 @@ class AuditClientListener @Inject constructor(
93
93
}
94
94
95
95
private fun idUrl (id : Id <DbBackfillRun >): String = backfilaConfig.web_url_root + BackfillShowAction .path(id.id)
96
+
97
+ private data class AuditEvent (
98
+ val backfillName : String ,
99
+ val run : DbBackfillRun ,
100
+ val description : String ,
101
+ )
96
102
}
0 commit comments