feat: M3 session similarity + contextual_match_score (closes M3) #23
+15
-3
@@ -126,8 +126,12 @@ class MutationReplayer @Inject constructor(
|
|||||||
}
|
}
|
||||||
true
|
true
|
||||||
} catch (
|
} catch (
|
||||||
@Suppress("TooGenericExceptionCaught") e: Throwable,
|
@Suppress("TooGenericExceptionCaught", "SwallowedException") e: Throwable,
|
||||||
) {
|
) {
|
||||||
|
// Intentional swallow: the row stays in the queue with
|
||||||
|
// attempts + lastAttemptAt incremented; next drain pass
|
||||||
|
// retries. Per-attempt diagnostic logging lands when we
|
||||||
|
// wire up Timber at the replayer level.
|
||||||
false
|
false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -147,8 +151,12 @@ class MutationReplayer @Inject constructor(
|
|||||||
discoverApi.createRequest(body)
|
discoverApi.createRequest(body)
|
||||||
true
|
true
|
||||||
} catch (
|
} catch (
|
||||||
@Suppress("TooGenericExceptionCaught") e: Throwable,
|
@Suppress("TooGenericExceptionCaught", "SwallowedException") e: Throwable,
|
||||||
) {
|
) {
|
||||||
|
// Intentional swallow: the row stays in the queue with
|
||||||
|
// attempts + lastAttemptAt incremented; next drain pass
|
||||||
|
// retries. Per-attempt diagnostic logging lands when we
|
||||||
|
// wire up Timber at the replayer level.
|
||||||
false
|
false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -159,8 +167,12 @@ class MutationReplayer @Inject constructor(
|
|||||||
quarantineApi.unflag(decoded.trackId)
|
quarantineApi.unflag(decoded.trackId)
|
||||||
true
|
true
|
||||||
} catch (
|
} catch (
|
||||||
@Suppress("TooGenericExceptionCaught") e: Throwable,
|
@Suppress("TooGenericExceptionCaught", "SwallowedException") e: Throwable,
|
||||||
) {
|
) {
|
||||||
|
// Intentional swallow: the row stays in the queue with
|
||||||
|
// attempts + lastAttemptAt incremented; next drain pass
|
||||||
|
// retries. Per-attempt diagnostic logging lands when we
|
||||||
|
// wire up Timber at the replayer level.
|
||||||
false
|
false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user