Skip to content

Commit

Permalink
fix lint warn
Browse files Browse the repository at this point in the history
  • Loading branch information
KSDaemon committed Jan 8, 2025
1 parent a23d964 commit 90bb390
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion packages/cubejs-backend-native/js/ResultWrapper.ts
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ export interface DataResult {
}

class BaseWrapper {
public readonly isWrapper: boolean = true;
public readonly isWrapper: boolean = true;
}

export class ResultWrapper extends BaseWrapper implements DataResult {
Expand Down
2 changes: 1 addition & 1 deletion packages/cubejs-clickhouse-driver/src/ClickHouseDriver.ts
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,7 @@ export class ClickHouseDriver extends BaseDriver implements DriverInterface {
},
};

const maxPoolSize = config.maxPoolSize ?? getEnv("dbMaxPoolSize", { dataSource }) ?? 8;
const maxPoolSize = config.maxPoolSize ?? getEnv('dbMaxPoolSize', { dataSource }) ?? 8;

this.client = this.createClient(maxPoolSize);
}
Expand Down
2 changes: 1 addition & 1 deletion packages/cubejs-server/src/websocket-server.ts
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ export class WebSocketServer {
// it again - it's too expensive, instead we serialize the rest of the message and then
// inject query result json into message.
const resMsg = new TextDecoder().decode(message.message);
message.message = "~XXXXX~";
message.message = '~XXXXX~';
messageStr = JSON.stringify(message);
messageStr = messageStr.replace('"~XXXXX~"', resMsg);
} else {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ export class KsqlDBRunner extends DbRunnerAbstract {
method: 'POST',
headers: { Accept: 'application/json' },
body: JSON.stringify({
ksql: "CREATE OR REPLACE STREAM REQUESTS (ID STRING, TIMESTAMP TIMESTAMP, TENANT_ID INTEGER, REQUEST_ID STRING) WITH (KAFKA_TOPIC = 'REQUESTS', KEY_FORMAT = 'JSON', PARTITIONS = 1, REPLICAS = 1, VALUE_FORMAT = 'JSON');",
ksql: 'CREATE OR REPLACE STREAM REQUESTS (ID STRING, TIMESTAMP TIMESTAMP, TENANT_ID INTEGER, REQUEST_ID STRING) WITH (KAFKA_TOPIC = \'REQUESTS\', KEY_FORMAT = \'JSON\', PARTITIONS = 1, REPLICAS = 1, VALUE_FORMAT = \'JSON\');',
streamsProperties: {}
})
});
Expand Down

0 comments on commit 90bb390

Please sign in to comment.