Skip to content

Commit

Permalink
fix InfluxDbSinkIT
Browse files Browse the repository at this point in the history
  • Loading branch information
danielfeismann committed Feb 22, 2024
1 parent 969b1e6 commit 081bcec
Showing 1 changed file with 1 addition and 4 deletions.
Expand Up @@ -55,7 +55,7 @@ class InfluxDbSinkIT extends Specification {
sink = new InfluxDbSink(connector)
fileNamingStrategy = new FileNamingStrategy()
}

static def timeUtil = TimeUtil.withDefaults

def "The test container can establish a valid connection"() {
when:
Expand Down Expand Up @@ -230,7 +230,6 @@ class InfluxDbSinkIT extends Specification {


static def mapMatchesLineResultEntity(Map<String, String> fieldMap, LineResult lineResult) {
def timeUtil = new TimeUtil(ZoneId.of("UTC"), Locale.GERMANY, "yyyy-MM-dd'T'HH:mm:ss[.S[S][S]]'Z'")
timeUtil.toZonedDateTime(fieldMap.get("time")) == lineResult.getTime()
fieldMap.get("uuid") == lineResult.getUuid().toString()
fieldMap.get("input_model") == lineResult.getInputModel().toString()
Expand All @@ -250,7 +249,6 @@ class InfluxDbSinkIT extends Specification {


static def mapMatchesChpResultEntity(Map<String, String> fieldMap, ChpResult chpResult) {
def timeUtil = new TimeUtil(ZoneId.of("UTC"), Locale.GERMANY, "yyyy-MM-dd'T'HH:mm:ss[.S[S][S]]'Z'")
timeUtil.toZonedDateTime(fieldMap.get("time")) == chpResult.getTime()
fieldMap.get("uuid") == chpResult.getUuid().toString()
fieldMap.get("input_model") == chpResult.getInputModel().toString()
Expand All @@ -263,7 +261,6 @@ class InfluxDbSinkIT extends Specification {
}

static def mapMatchesTimeBasedValue(Map<String, String> fieldMap, TimeBasedValue<PValue> pVal) {
def timeUtil = new TimeUtil(ZoneId.of("UTC"), Locale.GERMANY, "yyyy-MM-dd'T'HH:mm:ss[.S[S][S]]'Z'")
timeUtil.toZonedDateTime(fieldMap.get("time")) == pVal.getTime()
fieldMap.get("uuid") == pVal.getUuid().toString()
def pStr = fieldMap.get("p")
Expand Down

0 comments on commit 081bcec

Please sign in to comment.