Skip to content

Commit 00f1fa8

Browse files
authored
MINOR fix disable test (confluentinc#2382)
1 parent a4d58e0 commit 00f1fa8

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

src/Confluent.SchemaRegistry/Rest/RestService.cs

+1-2
Original file line numberDiff line numberDiff line change
@@ -238,8 +238,7 @@ private async Task<HttpResponseMessage> ExecuteOnOneInstanceAsync(Func<HttpReque
238238
string message = "";
239239
int errorCode = -1;
240240

241-
// 4xx errors with valid SR error message as content should not be retried (these are conclusive).
242-
if ((int)response.StatusCode >= 400 && (int)response.StatusCode < 500)
241+
if (!IsRetriable((int)response.StatusCode))
243242
{
244243
try
245244
{

test/Confluent.SchemaRegistry.Serdes.UnitTests/SerializeDeserialize.cs

+2
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
using Avro;
2828
using Avro.Generic;
2929
using Confluent.SchemaRegistry.Encryption;
30+
using Confluent.SchemaRegistry.Rules;
3031

3132

3233
namespace Confluent.SchemaRegistry.Serdes.UnitTests
@@ -325,6 +326,7 @@ public void ISpecificRecordCELFieldTransformDisable()
325326
UseLatestVersion = true
326327
};
327328
RuleRegistry registry = new RuleRegistry();
329+
registry.RegisterExecutor(new CelFieldExecutor());
328330
registry.RegisterOverride(new RuleOverride("CEL_FIELD", null, null, true));
329331
var serializer = new AvroSerializer<User>(schemaRegistryClient, config, registry);
330332
var deserializer = new AvroDeserializer<User>(schemaRegistryClient, null);

0 commit comments

Comments
 (0)