Skip to content

Commit 126a7be

Browse files
bednarbednar
committed
test: removed last() - see influxdata/influxdb#18897 
1 parent 70eafdf commit 126a7be

File tree

1 file changed

+22
-27
lines changed

1 file changed

+22
-27
lines changed

‎Client.Test/ItWriteQueryApiTest.cs‎

Lines changed: 22 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -101,8 +101,7 @@ public async Task DefaultTagsConfiguration()
101101

102102
_queryApi = Client.GetQueryApi();
103103
var tables = await _queryApi.QueryAsync(
104-
"from(bucket:\"" + _bucket.Name +
105-
"\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")",
104+
$"from(bucket:\"{_bucket.Name}\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")",
106105
_organization.Id);
107106

108107
Assert.AreEqual(1, tables.Count);
@@ -147,8 +146,7 @@ public async Task DefaultTagsMeasurement()
147146

148147
_queryApi = Client.GetQueryApi();
149148
var tables = await _queryApi.QueryAsync(
150-
"from(bucket:\"" + _bucket.Name +
151-
"\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")",
149+
$"from(bucket:\"{_bucket.Name}\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")",
152150
_organization.Id);
153151

154152
Assert.AreEqual(1, tables.Count);
@@ -191,8 +189,7 @@ public async Task DefaultTagsPoint()
191189

192190
_queryApi = Client.GetQueryApi();
193191
var tables = await _queryApi.QueryAsync(
194-
"from(bucket:\"" + _bucket.Name +
195-
"\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")",
192+
$"from(bucket:\"{_bucket.Name}\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")",
196193
_organization.Id);
197194

198195
Assert.AreEqual(1, tables.Count);
@@ -225,7 +222,7 @@ public async Task EnabledGzip()
225222
listener.WaitToSuccess();
226223

227224
var query = await _queryApi.QueryAsync(
228-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
225+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
229226
_organization.Id);
230227

231228
Assert.AreEqual(1, query.Count);
@@ -259,7 +256,7 @@ public async Task Flush()
259256
listener.WaitToSuccess();
260257

261258
var query = await _queryApi.QueryAsync(
262-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> last()",
259+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
263260
_organization.Id);
264261

265262
Assert.AreEqual(1, query.Count);
@@ -299,7 +296,7 @@ public async Task FlushByCount()
299296
_writeApi.WriteRecord(bucketName, _organization.Id, WritePrecision.Ns, record5);
300297

301298
var query = await _queryApi.QueryAsync(
302-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
299+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
303300
_organization.Id);
304301
Assert.AreEqual(0, query.Count);
305302

@@ -308,7 +305,7 @@ public async Task FlushByCount()
308305
listener.Get<WriteSuccessEvent>();
309306

310307
query = await _queryApi.QueryAsync(
311-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
308+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
312309
_organization.Id);
313310
Assert.AreEqual(1, query.Count);
314311

@@ -351,7 +348,7 @@ public async Task FlushByOne()
351348
Assert.AreEqual(record5, eventListener.Get<WriteSuccessEvent>().LineProtocol);
352349

353350
var query = await _queryApi.QueryAsync(
354-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000000Z)",
351+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000000Z)",
355352
_organization.Id);
356353
Assert.AreEqual(1, query.Count);
357354

@@ -383,14 +380,14 @@ public async Task FlushByTime()
383380
_writeApi.WriteRecord(bucketName, _organization.Id, WritePrecision.Ns, record5);
384381

385382
var query = await _queryApi.QueryAsync(
386-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
383+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
387384
_organization.Id);
388385
Assert.AreEqual(0, query.Count);
389386

390387
listener.Get<WriteSuccessEvent>();
391388

392389
query = await _queryApi.QueryAsync(
393-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
390+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
394391
_organization.Id);
395392
Assert.AreEqual(1, query.Count);
396393

@@ -412,14 +409,14 @@ public async Task Jitter()
412409
_writeApi.WriteRecord(bucketName, _organization.Id, WritePrecision.Ns, record);
413410

414411
var query = await _queryApi.QueryAsync(
415-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> last()",
412+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
416413
_organization.Id);
417414
Assert.AreEqual(0, query.Count);
418415

419416
Thread.Sleep(5_000);
420417

421418
query = await _queryApi.QueryAsync(
422-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> last()",
419+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
423420
_organization.Id);
424421

425422
Assert.AreEqual(1, query.Count);
@@ -481,7 +478,7 @@ public async Task PartialWrite()
481478
_writeApi.Dispose();
482479

483480
var query = await _queryApi.QueryAsync(
484-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> last()",
481+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> last()",
485482
_organization.Id);
486483
Assert.AreEqual(0, query.Count);
487484
}
@@ -561,7 +558,7 @@ public async Task Recovery()
561558
listener.Get<WriteSuccessEvent>();
562559

563560
var query = await _queryApi.QueryAsync(
564-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> last()",
561+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
565562
_organization.Id);
566563

567564
Assert.AreEqual(1, query.Count);
@@ -587,7 +584,7 @@ public async Task WriteAndQueryByOrganizationName()
587584
listener.WaitToSuccess();
588585

589586
var query = await _queryApi.QueryAsync(
590-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
587+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
591588
_organization.Name);
592589

593590
Assert.AreEqual(1, query.Count);
@@ -626,8 +623,7 @@ public async Task WriteMeasurements()
626623
_writeApi.Dispose();
627624

628625
var measurements = await _queryApi.QueryAsync<H20Measurement>(
629-
"from(bucket:\"" + bucketName +
630-
"\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> rename(columns:{_value: \"level\"})",
626+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z) |> rename(columns:{{_value: \"level\"}})",
631627
_organization.Id);
632628

633629
Assert.AreEqual(2, measurements.Count);
@@ -666,8 +662,7 @@ public async Task WriteMeasurementsWithoutFields()
666662
listener.WaitToSuccess();
667663

668664
var measurements = await _queryApi.QueryAsync<H20Measurement>(
669-
"from(bucket:\"" + bucketName +
670-
"\") |> range(start: 0) |> rename(columns:{_value: \"level\"})",
665+
$"from(bucket:\"{bucketName}\") |> range(start: 0) |> rename(columns:{{_value: \"level\"}})",
671666
_organization.Id);
672667

673668
Assert.AreEqual(1, measurements.Count);
@@ -704,7 +699,7 @@ public async Task WritePoints()
704699
listener.WaitToSuccess();
705700

706701
var query = await _queryApi.QueryAsync(
707-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
702+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
708703
_organization.Id);
709704

710705
Assert.AreEqual(1, query.Count);
@@ -750,7 +745,7 @@ public async Task WritePointsWithoutFields()
750745
listener.WaitToSuccess();
751746

752747
var query = await _queryApi.QueryAsync(
753-
"from(bucket:\"" + bucketName + "\") |> range(start: 0)",
748+
$"from(bucket:\"{bucketName}\") |> range(start: 0)",
754749
_organization.Id);
755750

756751
Assert.AreEqual(1, query.Count);
@@ -790,7 +785,7 @@ public async Task WriteQueryWithDefaultOrgBucket()
790785
listener.WaitToSuccess();
791786

792787
var query = await _queryApi.QueryAsync(
793-
"from(bucket:\"" + _bucket.Name + "\") |> range(start: 1970-01-01T00:00:00.000000001Z)");
788+
$"from(bucket:\"{_bucket.Name}\") |> range(start: 1970-01-01T00:00:00.000000001Z)");
794789

795790
Assert.AreEqual(1, query.Count);
796791

@@ -826,7 +821,7 @@ public async Task WriteRecordsList()
826821
listener.WaitToSuccess();
827822

828823
var query = await _queryApi.QueryAsync(
829-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
824+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
830825
_organization.Id);
831826

832827
Assert.AreEqual(1, query.Count);
@@ -858,7 +853,7 @@ public async Task WriteRecordsParams()
858853
listener.WaitToSuccess();
859854

860855
var query = await _queryApi.QueryAsync(
861-
"from(bucket:\"" + bucketName + "\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
856+
$"from(bucket:\"{bucketName}\") |> range(start: 1970-01-01T00:00:00.000000001Z)",
862857
_organization.Id);
863858

864859
Assert.AreEqual(1, query.Count);

0 commit comments

Comments
 (0)