diff --git a/go/pkg/repositories/application_logs_repository.go b/go/pkg/repositories/application_logs_repository.go
index a4bfe045..48cb300e 100644
--- a/go/pkg/repositories/application_logs_repository.go
+++ b/go/pkg/repositories/application_logs_repository.go
@@ -258,6 +258,7 @@ func (r *ElasticSearchApplicationLogsRepository) InsertLogs(ctx context.Context,
 	insertedLogs, err := bulk.Do(ctx)
 	if err != nil {
 		r.logger.Error("Failed to insert application logs", zap.Error(err))
+		return nil, err
 	}
 
 	ids := make([]string, 0, 0)