mirror of
https://github.com/getredash/redash.git
synced 2025-12-25 01:03:20 -05:00
Compare commits
10 Commits
25.05.0-de
...
25.07.0-de
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c9ddd2a7d6 | ||
|
|
6b1e910126 | ||
|
|
14550a9a6c | ||
|
|
b80c5f6a7c | ||
|
|
e46d44f208 | ||
|
|
a1a4bc9d3e | ||
|
|
0900178d24 | ||
|
|
5d31429ca8 | ||
|
|
2f35ceb803 | ||
|
|
8e6c02ecde |
3
.github/workflows/periodic-snapshot.yml
vendored
3
.github/workflows/periodic-snapshot.yml
vendored
@@ -2,7 +2,7 @@ name: Periodic Snapshot
|
||||
|
||||
on:
|
||||
schedule:
|
||||
- cron: '10 0 1 * *' # 10 minutes after midnight on the first of every month
|
||||
- cron: '10 0 1 * *' # 10 minutes after midnight on the first day of every month
|
||||
workflow_dispatch:
|
||||
inputs:
|
||||
bump:
|
||||
@@ -24,6 +24,7 @@ permissions:
|
||||
jobs:
|
||||
bump-version-and-tag:
|
||||
runs-on: ubuntu-latest
|
||||
if: github.ref_name == github.event.repository.default_branch
|
||||
steps:
|
||||
- uses: actions/checkout@v4
|
||||
with:
|
||||
|
||||
6
.github/workflows/preview-image.yml
vendored
6
.github/workflows/preview-image.yml
vendored
@@ -100,8 +100,8 @@ jobs:
|
||||
if: ${{ github.event.inputs.dockerRepository == 'preview' || !github.event.workflow_run }}
|
||||
with:
|
||||
tags: |
|
||||
${{ vars.DOCKER_USER }}/redash
|
||||
${{ vars.DOCKER_USER }}/preview
|
||||
${{ vars.DOCKER_REPOSITORY }}/redash
|
||||
${{ vars.DOCKER_REPOSITORY }}/preview
|
||||
context: .
|
||||
build-args: |
|
||||
test_all_deps=true
|
||||
@@ -117,7 +117,7 @@ jobs:
|
||||
if: ${{ github.event.inputs.dockerRepository == 'redash' }}
|
||||
with:
|
||||
tags: |
|
||||
${{ vars.DOCKER_USER }}/redash:${{ steps.version.outputs.VERSION_TAG }}
|
||||
${{ vars.DOCKER_REPOSITORY }}/redash:${{ steps.version.outputs.VERSION_TAG }}
|
||||
context: .
|
||||
build-args: |
|
||||
test_all_deps=true
|
||||
|
||||
@@ -9,7 +9,7 @@ const logger = debug("redash:services:QueryResult");
|
||||
const filterTypes = ["filter", "multi-filter", "multiFilter"];
|
||||
|
||||
function defer() {
|
||||
const result = { onStatusChange: status => {} };
|
||||
const result = { onStatusChange: (status) => {} };
|
||||
result.promise = new Promise((resolve, reject) => {
|
||||
result.resolve = resolve;
|
||||
result.reject = reject;
|
||||
@@ -40,13 +40,13 @@ function getColumnNameWithoutType(column) {
|
||||
}
|
||||
|
||||
function getColumnFriendlyName(column) {
|
||||
return getColumnNameWithoutType(column).replace(/(?:^|\s)\S/g, a => a.toUpperCase());
|
||||
return getColumnNameWithoutType(column).replace(/(?:^|\s)\S/g, (a) => a.toUpperCase());
|
||||
}
|
||||
|
||||
const createOrSaveUrl = data => (data.id ? `api/query_results/${data.id}` : "api/query_results");
|
||||
const createOrSaveUrl = (data) => (data.id ? `api/query_results/${data.id}` : "api/query_results");
|
||||
const QueryResultResource = {
|
||||
get: ({ id }) => axios.get(`api/query_results/${id}`),
|
||||
post: data => axios.post(createOrSaveUrl(data), data),
|
||||
post: (data) => axios.post(createOrSaveUrl(data), data),
|
||||
};
|
||||
|
||||
export const ExecutionStatus = {
|
||||
@@ -97,11 +97,11 @@ function handleErrorResponse(queryResult, error) {
|
||||
}
|
||||
|
||||
function sleep(ms) {
|
||||
return new Promise(resolve => setTimeout(resolve, ms));
|
||||
return new Promise((resolve) => setTimeout(resolve, ms));
|
||||
}
|
||||
|
||||
export function fetchDataFromJob(jobId, interval = 1000) {
|
||||
return axios.get(`api/jobs/${jobId}`).then(data => {
|
||||
return axios.get(`api/jobs/${jobId}`).then((data) => {
|
||||
const status = statuses[data.job.status];
|
||||
if (status === ExecutionStatus.WAITING || status === ExecutionStatus.PROCESSING) {
|
||||
return sleep(interval).then(() => fetchDataFromJob(data.job.id));
|
||||
@@ -146,7 +146,7 @@ class QueryResult {
|
||||
// TODO: we should stop manipulating incoming data, and switch to relaying
|
||||
// on the column type set by the backend. This logic is prone to errors,
|
||||
// and better be removed. Kept for now, for backward compatability.
|
||||
each(this.query_result.data.rows, row => {
|
||||
each(this.query_result.data.rows, (row) => {
|
||||
forOwn(row, (v, k) => {
|
||||
let newType = null;
|
||||
if (isNumber(v)) {
|
||||
@@ -173,7 +173,7 @@ class QueryResult {
|
||||
});
|
||||
});
|
||||
|
||||
each(this.query_result.data.columns, column => {
|
||||
each(this.query_result.data.columns, (column) => {
|
||||
column.name = "" + column.name;
|
||||
if (columnTypes[column.name]) {
|
||||
if (column.type == null || column.type === "string") {
|
||||
@@ -265,14 +265,14 @@ class QueryResult {
|
||||
|
||||
getColumnNames() {
|
||||
if (this.columnNames === undefined && this.query_result.data) {
|
||||
this.columnNames = this.query_result.data.columns.map(v => v.name);
|
||||
this.columnNames = this.query_result.data.columns.map((v) => v.name);
|
||||
}
|
||||
|
||||
return this.columnNames;
|
||||
}
|
||||
|
||||
getColumnFriendlyNames() {
|
||||
return this.getColumnNames().map(col => getColumnFriendlyName(col));
|
||||
return this.getColumnNames().map((col) => getColumnFriendlyName(col));
|
||||
}
|
||||
|
||||
getTruncated() {
|
||||
@@ -286,7 +286,7 @@ class QueryResult {
|
||||
|
||||
const filters = [];
|
||||
|
||||
this.getColumns().forEach(col => {
|
||||
this.getColumns().forEach((col) => {
|
||||
const name = col.name;
|
||||
const type = name.split("::")[1] || name.split("__")[1];
|
||||
if (includes(filterTypes, type)) {
|
||||
@@ -302,8 +302,8 @@ class QueryResult {
|
||||
}
|
||||
}, this);
|
||||
|
||||
this.getRawData().forEach(row => {
|
||||
filters.forEach(filter => {
|
||||
this.getRawData().forEach((row) => {
|
||||
filters.forEach((filter) => {
|
||||
filter.values.push(row[filter.name]);
|
||||
if (filter.values.length === 1) {
|
||||
if (filter.multiple) {
|
||||
@@ -315,8 +315,8 @@ class QueryResult {
|
||||
});
|
||||
});
|
||||
|
||||
filters.forEach(filter => {
|
||||
filter.values = uniqBy(filter.values, v => {
|
||||
filters.forEach((filter) => {
|
||||
filter.values = uniqBy(filter.values, (v) => {
|
||||
if (moment.isMoment(v)) {
|
||||
return v.unix();
|
||||
}
|
||||
@@ -345,12 +345,12 @@ class QueryResult {
|
||||
|
||||
axios
|
||||
.get(`api/queries/${queryId}/results/${id}.json`)
|
||||
.then(response => {
|
||||
.then((response) => {
|
||||
// Success handler
|
||||
queryResult.isLoadingResult = false;
|
||||
queryResult.update(response);
|
||||
})
|
||||
.catch(error => {
|
||||
.catch((error) => {
|
||||
// Error handler
|
||||
queryResult.isLoadingResult = false;
|
||||
handleErrorResponse(queryResult, error);
|
||||
@@ -362,10 +362,10 @@ class QueryResult {
|
||||
loadLatestCachedResult(queryId, parameters) {
|
||||
axios
|
||||
.post(`api/queries/${queryId}/results`, { queryId, parameters })
|
||||
.then(response => {
|
||||
.then((response) => {
|
||||
this.update(response);
|
||||
})
|
||||
.catch(error => {
|
||||
.catch((error) => {
|
||||
handleErrorResponse(this, error);
|
||||
});
|
||||
}
|
||||
@@ -375,11 +375,11 @@ class QueryResult {
|
||||
this.deferred.onStatusChange(ExecutionStatus.LOADING_RESULT);
|
||||
|
||||
QueryResultResource.get({ id: this.job.query_result_id })
|
||||
.then(response => {
|
||||
.then((response) => {
|
||||
this.update(response);
|
||||
this.isLoadingResult = false;
|
||||
})
|
||||
.catch(error => {
|
||||
.catch((error) => {
|
||||
if (tryCount === undefined) {
|
||||
tryCount = 0;
|
||||
}
|
||||
@@ -394,9 +394,12 @@ class QueryResult {
|
||||
});
|
||||
this.isLoadingResult = false;
|
||||
} else {
|
||||
setTimeout(() => {
|
||||
this.loadResult(tryCount + 1);
|
||||
}, 1000 * Math.pow(2, tryCount));
|
||||
setTimeout(
|
||||
() => {
|
||||
this.loadResult(tryCount + 1);
|
||||
},
|
||||
1000 * Math.pow(2, tryCount)
|
||||
);
|
||||
}
|
||||
});
|
||||
}
|
||||
@@ -410,19 +413,26 @@ class QueryResult {
|
||||
: axios.get(`api/queries/${query}/jobs/${this.job.id}`);
|
||||
|
||||
request
|
||||
.then(jobResponse => {
|
||||
.then((jobResponse) => {
|
||||
this.update(jobResponse);
|
||||
|
||||
if (this.getStatus() === "processing" && this.job.query_result_id && this.job.query_result_id !== "None") {
|
||||
loadResult();
|
||||
} else if (this.getStatus() !== "failed") {
|
||||
const waitTime = tryNumber > 10 ? 3000 : 500;
|
||||
let waitTime;
|
||||
if (tryNumber <= 10) {
|
||||
waitTime = 500;
|
||||
} else if (tryNumber <= 50) {
|
||||
waitTime = 1000;
|
||||
} else {
|
||||
waitTime = 3000;
|
||||
}
|
||||
setTimeout(() => {
|
||||
this.refreshStatus(query, parameters, tryNumber + 1);
|
||||
}, waitTime);
|
||||
}
|
||||
})
|
||||
.catch(error => {
|
||||
.catch((error) => {
|
||||
logger("Connection error", error);
|
||||
// TODO: use QueryResultError, or better yet: exception/reject of promise.
|
||||
this.update({
|
||||
@@ -451,14 +461,14 @@ class QueryResult {
|
||||
|
||||
axios
|
||||
.post(`api/queries/${id}/results`, { id, parameters, apply_auto_limit: applyAutoLimit, max_age: maxAge })
|
||||
.then(response => {
|
||||
.then((response) => {
|
||||
queryResult.update(response);
|
||||
|
||||
if ("job" in response) {
|
||||
queryResult.refreshStatus(id, parameters);
|
||||
}
|
||||
})
|
||||
.catch(error => {
|
||||
.catch((error) => {
|
||||
handleErrorResponse(queryResult, error);
|
||||
});
|
||||
|
||||
@@ -481,14 +491,14 @@ class QueryResult {
|
||||
}
|
||||
|
||||
QueryResultResource.post(params)
|
||||
.then(response => {
|
||||
.then((response) => {
|
||||
queryResult.update(response);
|
||||
|
||||
if ("job" in response) {
|
||||
queryResult.refreshStatus(query, parameters);
|
||||
}
|
||||
})
|
||||
.catch(error => {
|
||||
.catch((error) => {
|
||||
handleErrorResponse(queryResult, error);
|
||||
});
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "redash-client",
|
||||
"version": "25.05.0-dev",
|
||||
"version": "25.07.0-dev",
|
||||
"description": "The frontend part of Redash.",
|
||||
"main": "index.js",
|
||||
"scripts": {
|
||||
@@ -143,6 +143,7 @@
|
||||
"react-refresh": "^0.14.0",
|
||||
"react-test-renderer": "^16.14.0",
|
||||
"request-cookies": "^1.1.0",
|
||||
"source-map-loader": "^1.1.3",
|
||||
"style-loader": "^2.0.0",
|
||||
"typescript": "^4.1.2",
|
||||
"url-loader": "^4.1.1",
|
||||
|
||||
2753
poetry.lock
generated
2753
poetry.lock
generated
File diff suppressed because it is too large
Load Diff
@@ -12,7 +12,7 @@ force-exclude = '''
|
||||
|
||||
[tool.poetry]
|
||||
name = "redash"
|
||||
version = "25.05.0-dev"
|
||||
version = "25.07.0-dev"
|
||||
description = "Make Your Company Data Driven. Connect to any data source, easily visualize, dashboard and share your data."
|
||||
authors = ["Arik Fraimovich <arik@redash.io>"]
|
||||
# to be added to/removed from the mailing list, please reach out to Arik via the above email or Discord
|
||||
@@ -95,7 +95,7 @@ optional = true
|
||||
|
||||
[tool.poetry.group.all_ds.dependencies]
|
||||
atsd-client = "3.0.5"
|
||||
azure-kusto-data = "0.0.35"
|
||||
azure-kusto-data = "5.0.1"
|
||||
boto3 = "1.28.8"
|
||||
botocore = "1.31.8"
|
||||
cassandra-driver = "3.21.0"
|
||||
@@ -110,6 +110,7 @@ influxdb = "5.2.3"
|
||||
influxdb-client = "1.38.0"
|
||||
memsql = "3.2.0"
|
||||
mysqlclient = "2.1.1"
|
||||
numpy = "1.24.4"
|
||||
nzalchemy = "^11.0.2"
|
||||
nzpy = ">=1.15"
|
||||
oauth2client = "4.1.3"
|
||||
|
||||
@@ -14,7 +14,7 @@ from redash.app import create_app # noqa
|
||||
from redash.destinations import import_destinations
|
||||
from redash.query_runner import import_query_runners
|
||||
|
||||
__version__ = "25.05.0-dev"
|
||||
__version__ = "25.07.0-dev"
|
||||
|
||||
|
||||
if os.environ.get("REMOTE_DEBUG"):
|
||||
|
||||
@@ -288,7 +288,10 @@ class BaseSQLQueryRunner(BaseQueryRunner):
|
||||
return True
|
||||
|
||||
def query_is_select_no_limit(self, query):
|
||||
parsed_query = sqlparse.parse(query)[0]
|
||||
parsed_query_list = sqlparse.parse(query)
|
||||
if len(parsed_query_list) == 0:
|
||||
return False
|
||||
parsed_query = parsed_query_list[0]
|
||||
last_keyword_idx = find_last_keyword_idx(parsed_query)
|
||||
# Either invalid query or query that is not select
|
||||
if last_keyword_idx == -1 or parsed_query.tokens[0].value.upper() != "SELECT":
|
||||
|
||||
@@ -11,12 +11,12 @@ from redash.query_runner import (
|
||||
from redash.utils import json_loads
|
||||
|
||||
try:
|
||||
from azure.kusto.data.exceptions import KustoServiceError
|
||||
from azure.kusto.data.request import (
|
||||
from azure.kusto.data import (
|
||||
ClientRequestProperties,
|
||||
KustoClient,
|
||||
KustoConnectionStringBuilder,
|
||||
)
|
||||
from azure.kusto.data.exceptions import KustoServiceError
|
||||
|
||||
enabled = True
|
||||
except ImportError:
|
||||
@@ -37,6 +37,34 @@ TYPES_MAP = {
|
||||
}
|
||||
|
||||
|
||||
def _get_data_scanned(kusto_response):
|
||||
try:
|
||||
metadata_table = next(
|
||||
(table for table in kusto_response.tables if table.table_name == "QueryCompletionInformation"),
|
||||
None,
|
||||
)
|
||||
|
||||
if metadata_table:
|
||||
resource_usage_json = next(
|
||||
(row["Payload"] for row in metadata_table.rows if row["EventTypeName"] == "QueryResourceConsumption"),
|
||||
"{}",
|
||||
)
|
||||
resource_usage = json_loads(resource_usage_json).get("resource_usage", {})
|
||||
|
||||
data_scanned = (
|
||||
resource_usage["cache"]["shards"]["cold"]["hitbytes"]
|
||||
+ resource_usage["cache"]["shards"]["cold"]["missbytes"]
|
||||
+ resource_usage["cache"]["shards"]["hot"]["hitbytes"]
|
||||
+ resource_usage["cache"]["shards"]["hot"]["missbytes"]
|
||||
+ resource_usage["cache"]["shards"]["bypassbytes"]
|
||||
)
|
||||
|
||||
except Exception:
|
||||
data_scanned = 0
|
||||
|
||||
return int(data_scanned)
|
||||
|
||||
|
||||
class AzureKusto(BaseQueryRunner):
|
||||
should_annotate_query = False
|
||||
noop_query = "let noop = datatable (Noop:string)[1]; noop"
|
||||
@@ -44,8 +72,6 @@ class AzureKusto(BaseQueryRunner):
|
||||
def __init__(self, configuration):
|
||||
super(AzureKusto, self).__init__(configuration)
|
||||
self.syntax = "custom"
|
||||
self.client_request_properties = ClientRequestProperties()
|
||||
self.client_request_properties.application = "redash"
|
||||
|
||||
@classmethod
|
||||
def configuration_schema(cls):
|
||||
@@ -60,12 +86,14 @@ class AzureKusto(BaseQueryRunner):
|
||||
},
|
||||
"azure_ad_tenant_id": {"type": "string", "title": "Azure AD Tenant Id"},
|
||||
"database": {"type": "string"},
|
||||
"msi": {"type": "boolean", "title": "Use Managed Service Identity"},
|
||||
"user_msi": {
|
||||
"type": "string",
|
||||
"title": "User-assigned managed identity client ID",
|
||||
},
|
||||
},
|
||||
"required": [
|
||||
"cluster",
|
||||
"azure_ad_client_id",
|
||||
"azure_ad_client_secret",
|
||||
"azure_ad_tenant_id",
|
||||
"database",
|
||||
],
|
||||
"order": [
|
||||
@@ -91,18 +119,48 @@ class AzureKusto(BaseQueryRunner):
|
||||
return "Azure Data Explorer (Kusto)"
|
||||
|
||||
def run_query(self, query, user):
|
||||
kcsb = KustoConnectionStringBuilder.with_aad_application_key_authentication(
|
||||
connection_string=self.configuration["cluster"],
|
||||
aad_app_id=self.configuration["azure_ad_client_id"],
|
||||
app_key=self.configuration["azure_ad_client_secret"],
|
||||
authority_id=self.configuration["azure_ad_tenant_id"],
|
||||
)
|
||||
cluster = self.configuration["cluster"]
|
||||
msi = self.configuration.get("msi", False)
|
||||
# Managed Service Identity(MSI)
|
||||
if msi:
|
||||
# If user-assigned managed identity is used, the client ID must be provided
|
||||
if self.configuration.get("user_msi"):
|
||||
kcsb = KustoConnectionStringBuilder.with_aad_managed_service_identity_authentication(
|
||||
cluster,
|
||||
client_id=self.configuration["user_msi"],
|
||||
)
|
||||
else:
|
||||
kcsb = KustoConnectionStringBuilder.with_aad_managed_service_identity_authentication(cluster)
|
||||
# Service Principal auth
|
||||
else:
|
||||
aad_app_id = self.configuration.get("azure_ad_client_id")
|
||||
app_key = self.configuration.get("azure_ad_client_secret")
|
||||
authority_id = self.configuration.get("azure_ad_tenant_id")
|
||||
|
||||
if not (aad_app_id and app_key and authority_id):
|
||||
raise ValueError(
|
||||
"Azure AD Client ID, Client Secret, and Tenant ID are required for Service Principal authentication."
|
||||
)
|
||||
|
||||
kcsb = KustoConnectionStringBuilder.with_aad_application_key_authentication(
|
||||
connection_string=cluster,
|
||||
aad_app_id=aad_app_id,
|
||||
app_key=app_key,
|
||||
authority_id=authority_id,
|
||||
)
|
||||
|
||||
client = KustoClient(kcsb)
|
||||
|
||||
request_properties = ClientRequestProperties()
|
||||
request_properties.application = "redash"
|
||||
|
||||
if user:
|
||||
request_properties.user = user.email
|
||||
request_properties.set_option("request_description", user.email)
|
||||
|
||||
db = self.configuration["database"]
|
||||
try:
|
||||
response = client.execute(db, query, self.client_request_properties)
|
||||
response = client.execute(db, query, request_properties)
|
||||
|
||||
result_cols = response.primary_results[0].columns
|
||||
result_rows = response.primary_results[0].rows
|
||||
@@ -123,14 +181,15 @@ class AzureKusto(BaseQueryRunner):
|
||||
rows.append(row.to_dict())
|
||||
|
||||
error = None
|
||||
data = {"columns": columns, "rows": rows}
|
||||
data = {
|
||||
"columns": columns,
|
||||
"rows": rows,
|
||||
"metadata": {"data_scanned": _get_data_scanned(response)},
|
||||
}
|
||||
|
||||
except KustoServiceError as err:
|
||||
data = None
|
||||
try:
|
||||
error = err.args[1][0]["error"]["@message"]
|
||||
except (IndexError, KeyError):
|
||||
error = err.args[1]
|
||||
error = str(err)
|
||||
|
||||
return data, error
|
||||
|
||||
@@ -143,7 +202,10 @@ class AzureKusto(BaseQueryRunner):
|
||||
self._handle_run_query_error(error)
|
||||
|
||||
schema_as_json = json_loads(results["rows"][0]["DatabaseSchema"])
|
||||
tables_list = schema_as_json["Databases"][self.configuration["database"]]["Tables"].values()
|
||||
tables_list = [
|
||||
*(schema_as_json["Databases"][self.configuration["database"]]["Tables"].values()),
|
||||
*(schema_as_json["Databases"][self.configuration["database"]]["MaterializedViews"].values()),
|
||||
]
|
||||
|
||||
schema = {}
|
||||
|
||||
@@ -154,7 +216,9 @@ class AzureKusto(BaseQueryRunner):
|
||||
schema[table_name] = {"name": table_name, "columns": []}
|
||||
|
||||
for column in table["OrderedColumns"]:
|
||||
schema[table_name]["columns"].append(column["Name"])
|
||||
schema[table_name]["columns"].append(
|
||||
{"name": column["Name"], "type": TYPES_MAP.get(column["CslType"], None)}
|
||||
)
|
||||
|
||||
return list(schema.values())
|
||||
|
||||
|
||||
42
tests/query_runner/test_azure_kusto.py
Normal file
42
tests/query_runner/test_azure_kusto.py
Normal file
@@ -0,0 +1,42 @@
|
||||
from unittest import TestCase
|
||||
from unittest.mock import patch
|
||||
|
||||
from redash.query_runner.azure_kusto import AzureKusto
|
||||
|
||||
|
||||
class TestAzureKusto(TestCase):
|
||||
def setUp(self):
|
||||
self.configuration = {
|
||||
"cluster": "https://example.kusto.windows.net",
|
||||
"database": "sample_db",
|
||||
"azure_ad_client_id": "client_id",
|
||||
"azure_ad_client_secret": "client_secret",
|
||||
"azure_ad_tenant_id": "tenant_id",
|
||||
}
|
||||
self.kusto = AzureKusto(self.configuration)
|
||||
|
||||
@patch.object(AzureKusto, "run_query")
|
||||
def test_get_schema(self, mock_run_query):
|
||||
mock_response = {
|
||||
"rows": [
|
||||
{
|
||||
"DatabaseSchema": '{"Databases":{"sample_db":{"Tables":{"Table1":{"Name":"Table1","OrderedColumns":[{"Name":"Column1","Type":"System.String","CslType":"string"},{"Name":"Column2","Type":"System.DateTime","CslType":"datetime"}]}},"MaterializedViews":{"View1":{"Name":"View1","OrderedColumns":[{"Name":"Column1","Type":"System.String","CslType":"string"},{"Name":"Column2","Type":"System.DateTime","CslType":"datetime"}]}}}}}'
|
||||
}
|
||||
]
|
||||
}
|
||||
mock_run_query.return_value = (mock_response, None)
|
||||
|
||||
expected_schema = [
|
||||
{
|
||||
"name": "Table1",
|
||||
"columns": [{"name": "Column1", "type": "string"}, {"name": "Column2", "type": "datetime"}],
|
||||
},
|
||||
{
|
||||
"name": "View1",
|
||||
"columns": [{"name": "Column1", "type": "string"}, {"name": "Column2", "type": "datetime"}],
|
||||
},
|
||||
]
|
||||
|
||||
schema = self.kusto.get_schema()
|
||||
print(schema)
|
||||
self.assertEqual(schema, expected_schema)
|
||||
@@ -28,4 +28,4 @@ class TestJsonDumps(BaseTestCase):
|
||||
}
|
||||
json_data = json_dumps(input_data)
|
||||
actual_output_data = json_loads(json_data)
|
||||
self.assertEquals(actual_output_data, expected_output_data)
|
||||
self.assertEqual(actual_output_data, expected_output_data)
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
import * as Plotly from "plotly.js";
|
||||
|
||||
import "./locales"
|
||||
import prepareData from "./prepareData";
|
||||
import prepareLayout from "./prepareLayout";
|
||||
import updateData from "./updateData";
|
||||
@@ -11,6 +12,7 @@ import { prepareCustomChartData, createCustomChartRenderer } from "./customChart
|
||||
Plotly.setPlotConfig({
|
||||
modeBarButtonsToRemove: ["sendDataToCloud"],
|
||||
modeBarButtonsToAdd: ["togglespikelines", "v1hovermode"],
|
||||
locale: window.navigator.language,
|
||||
});
|
||||
|
||||
export {
|
||||
|
||||
230
viz-lib/src/visualizations/chart/plotly/locales.ts
Normal file
230
viz-lib/src/visualizations/chart/plotly/locales.ts
Normal file
@@ -0,0 +1,230 @@
|
||||
import * as Plotly from "plotly.js";
|
||||
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeAf from "plotly.js/lib/locales/af";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeAm from "plotly.js/lib/locales/am";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeAr_dz from "plotly.js/lib/locales/ar-dz";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeAr_eg from "plotly.js/lib/locales/ar-eg";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeAr from "plotly.js/lib/locales/ar";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeAz from "plotly.js/lib/locales/az";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeBg from "plotly.js/lib/locales/bg";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeBs from "plotly.js/lib/locales/bs";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeCa from "plotly.js/lib/locales/ca";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeCs from "plotly.js/lib/locales/cs";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeCy from "plotly.js/lib/locales/cy";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeDa from "plotly.js/lib/locales/da";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeDe_ch from "plotly.js/lib/locales/de-ch";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeDe from "plotly.js/lib/locales/de";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeEl from "plotly.js/lib/locales/el";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeEo from "plotly.js/lib/locales/eo";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeEs_ar from "plotly.js/lib/locales/es-ar";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeEs_pe from "plotly.js/lib/locales/es-pe";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeEs from "plotly.js/lib/locales/es";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeEt from "plotly.js/lib/locales/et";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeEu from "plotly.js/lib/locales/eu";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeFa from "plotly.js/lib/locales/fa";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeFi from "plotly.js/lib/locales/fi";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeFo from "plotly.js/lib/locales/fo";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeFr_ch from "plotly.js/lib/locales/fr-ch";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeFr from "plotly.js/lib/locales/fr";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeGl from "plotly.js/lib/locales/gl";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeGu from "plotly.js/lib/locales/gu";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeHe from "plotly.js/lib/locales/he";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeHi_in from "plotly.js/lib/locales/hi-in";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeHr from "plotly.js/lib/locales/hr";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeHu from "plotly.js/lib/locales/hu";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeHy from "plotly.js/lib/locales/hy";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeId from "plotly.js/lib/locales/id";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeIs from "plotly.js/lib/locales/is";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeIt from "plotly.js/lib/locales/it";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeJa from "plotly.js/lib/locales/ja";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeKa from "plotly.js/lib/locales/ka";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeKm from "plotly.js/lib/locales/km";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeKo from "plotly.js/lib/locales/ko";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeLt from "plotly.js/lib/locales/lt";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeLv from "plotly.js/lib/locales/lv";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeMe_me from "plotly.js/lib/locales/me-me";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeMe from "plotly.js/lib/locales/me";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeMk from "plotly.js/lib/locales/mk";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeMl from "plotly.js/lib/locales/ml";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeMs from "plotly.js/lib/locales/ms";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeMt from "plotly.js/lib/locales/mt";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeNl_be from "plotly.js/lib/locales/nl-be";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeNl from "plotly.js/lib/locales/nl";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeNo from "plotly.js/lib/locales/no";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localePa from "plotly.js/lib/locales/pa";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localePl from "plotly.js/lib/locales/pl";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localePt_br from "plotly.js/lib/locales/pt-br";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localePt_pt from "plotly.js/lib/locales/pt-pt";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeRm from "plotly.js/lib/locales/rm";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeRo from "plotly.js/lib/locales/ro";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeRu from "plotly.js/lib/locales/ru";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeSk from "plotly.js/lib/locales/sk";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeSl from "plotly.js/lib/locales/sl";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeSq from "plotly.js/lib/locales/sq";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeSr_sr from "plotly.js/lib/locales/sr-sr";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeSr from "plotly.js/lib/locales/sr";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeSv from "plotly.js/lib/locales/sv";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeSw from "plotly.js/lib/locales/sw";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeTa from "plotly.js/lib/locales/ta";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeTh from "plotly.js/lib/locales/th";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeTr from "plotly.js/lib/locales/tr";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeTt from "plotly.js/lib/locales/tt";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeUk from "plotly.js/lib/locales/uk";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeUr from "plotly.js/lib/locales/ur";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeVi from "plotly.js/lib/locales/vi";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeZh_cn from "plotly.js/lib/locales/zh-cn";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeZh_hk from "plotly.js/lib/locales/zh-hk";
|
||||
// @ts-expect-error ts-migrate(7016) FIXME: Could not find a declaration file for module
|
||||
import localeZh_tw from "plotly.js/lib/locales/zh-tw";
|
||||
|
||||
(Plotly as any).register([
|
||||
localeAf,
|
||||
localeAm,
|
||||
localeAr_dz,
|
||||
localeAr_eg,
|
||||
localeAr,
|
||||
localeAz,
|
||||
localeBg,
|
||||
localeBs,
|
||||
localeCa,
|
||||
localeCs,
|
||||
localeCy,
|
||||
localeDa,
|
||||
localeDe_ch,
|
||||
localeDe,
|
||||
localeEl,
|
||||
localeEo,
|
||||
localeEs_ar,
|
||||
localeEs_pe,
|
||||
localeEs,
|
||||
localeEt,
|
||||
localeEu,
|
||||
localeFa,
|
||||
localeFi,
|
||||
localeFo,
|
||||
localeFr_ch,
|
||||
localeFr,
|
||||
localeGl,
|
||||
localeGu,
|
||||
localeHe,
|
||||
localeHi_in,
|
||||
localeHr,
|
||||
localeHu,
|
||||
localeHy,
|
||||
localeId,
|
||||
localeIs,
|
||||
localeIt,
|
||||
localeJa,
|
||||
localeKa,
|
||||
localeKm,
|
||||
localeKo,
|
||||
localeLt,
|
||||
localeLv,
|
||||
localeMe_me,
|
||||
localeMe,
|
||||
localeMk,
|
||||
localeMl,
|
||||
localeMs,
|
||||
localeMt,
|
||||
localeNl_be,
|
||||
localeNl,
|
||||
localeNo,
|
||||
localePa,
|
||||
localePl,
|
||||
localePt_br,
|
||||
localePt_pt,
|
||||
localeRm,
|
||||
localeRo,
|
||||
localeRu,
|
||||
localeSk,
|
||||
localeSl,
|
||||
localeSq,
|
||||
localeSr_sr,
|
||||
localeSr,
|
||||
localeSv,
|
||||
localeSw,
|
||||
localeTa,
|
||||
localeTh,
|
||||
localeTr,
|
||||
localeTt,
|
||||
localeUk,
|
||||
localeUr,
|
||||
localeVi,
|
||||
localeZh_cn,
|
||||
localeZh_hk,
|
||||
localeZh_tw,
|
||||
]);
|
||||
@@ -133,6 +133,11 @@ const config = {
|
||||
},
|
||||
module: {
|
||||
rules: [
|
||||
{
|
||||
test: /\.js$/,
|
||||
enforce: "pre",
|
||||
use: ["source-map-loader"],
|
||||
},
|
||||
{
|
||||
test: /\.(t|j)sx?$/,
|
||||
exclude: /node_modules/,
|
||||
|
||||
25
yarn.lock
25
yarn.lock
@@ -2624,7 +2624,7 @@
|
||||
resolved "https://registry.yarnpkg.com/@xtuc/long/-/long-4.2.2.tgz#d291c6a4e97989b5c61d9acf396ae4fe133a718d"
|
||||
integrity sha512-NuHqBY1PB/D8xU6s/thBgOAiAP7HOYDQ32+BFZILJ8ivkUkAHQnWfn6WhL79Owj1qmUnoN/YPhktdIoucipkAQ==
|
||||
|
||||
abab@^2.0.0:
|
||||
abab@^2.0.0, abab@^2.0.5:
|
||||
version "2.0.6"
|
||||
resolved "https://registry.yarnpkg.com/abab/-/abab-2.0.6.tgz#41b80f2c871d19686216b82309231cfd3cb3d291"
|
||||
integrity sha512-j2afSsaIENvHZN2B8GOpF566vZ5WVk5opAiMTvWgaQT8DkbOqsTfvNAvHoRGU2zzP8cPoqys+xHTRDWW8L+/BA==
|
||||
@@ -7745,6 +7745,13 @@ iconv-lite@0.4.24, iconv-lite@^0.4.24, iconv-lite@^0.4.4:
|
||||
dependencies:
|
||||
safer-buffer ">= 2.1.2 < 3"
|
||||
|
||||
iconv-lite@^0.6.2:
|
||||
version "0.6.3"
|
||||
resolved "https://registry.yarnpkg.com/iconv-lite/-/iconv-lite-0.6.3.tgz#a52f80bf38da1952eb5c681790719871a1a72501"
|
||||
integrity sha512-4fCk79wshMdzMp2rH06qWrJE4iolqLhCUH+OiuIgU++RB0+94NlDL81atO7GX55uUKueo0txHNtvEyI6D7WdMw==
|
||||
dependencies:
|
||||
safer-buffer ">= 2.1.2 < 3.0.0"
|
||||
|
||||
icss-utils@^5.0.0, icss-utils@^5.1.0:
|
||||
version "5.1.0"
|
||||
resolved "https://registry.yarnpkg.com/icss-utils/-/icss-utils-5.1.0.tgz#c6be6858abd013d768e98366ae47e25d5887b1ae"
|
||||
@@ -12650,7 +12657,7 @@ safe-regex@^1.1.0:
|
||||
dependencies:
|
||||
ret "~0.1.10"
|
||||
|
||||
"safer-buffer@>= 2.1.2 < 3", safer-buffer@^2.0.2, safer-buffer@^2.1.0, safer-buffer@~2.1.0:
|
||||
"safer-buffer@>= 2.1.2 < 3", "safer-buffer@>= 2.1.2 < 3.0.0", safer-buffer@^2.0.2, safer-buffer@^2.1.0, safer-buffer@~2.1.0:
|
||||
version "2.1.2"
|
||||
resolved "https://registry.yarnpkg.com/safer-buffer/-/safer-buffer-2.1.2.tgz#44fa161b0187b9549dd84bb91802f9bd8385cd6a"
|
||||
integrity sha512-YZo3K82SD7Riyi0E1EQPojLz7kpepnSQI9IyPbHHg1XXXevb5dJI7tpyN2ADxGcQbHG7vcyRHk0cbwqcQriUtg==
|
||||
@@ -13069,6 +13076,18 @@ source-map-js@^1.2.1:
|
||||
resolved "https://registry.yarnpkg.com/source-map-js/-/source-map-js-1.2.1.tgz#1ce5650fddd87abc099eda37dcff024c2667ae46"
|
||||
integrity sha512-UXWMKhLOwVKb728IUtQPXxfYU+usdybtUrK/8uGE8CQMvrhOpwvzDBwj0QhSL7MQc7vIsISBG8VQ8+IDQxpfQA==
|
||||
|
||||
source-map-loader@^1.1.3:
|
||||
version "1.1.3"
|
||||
resolved "https://registry.yarnpkg.com/source-map-loader/-/source-map-loader-1.1.3.tgz#7dbc2fe7ea09d3e43c51fd9fc478b7f016c1f820"
|
||||
integrity sha512-6YHeF+XzDOrT/ycFJNI53cgEsp/tHTMl37hi7uVyqFAlTXW109JazaQCkbc+jjoL2637qkH1amLi+JzrIpt5lA==
|
||||
dependencies:
|
||||
abab "^2.0.5"
|
||||
iconv-lite "^0.6.2"
|
||||
loader-utils "^2.0.0"
|
||||
schema-utils "^3.0.0"
|
||||
source-map "^0.6.1"
|
||||
whatwg-mimetype "^2.3.0"
|
||||
|
||||
source-map-resolve@^0.5.0:
|
||||
version "0.5.3"
|
||||
resolved "https://registry.yarnpkg.com/source-map-resolve/-/source-map-resolve-0.5.3.tgz#190866bece7553e1f8f267a2ee82c606b5509a1a"
|
||||
@@ -14714,7 +14733,7 @@ whatwg-encoding@^1.0.1, whatwg-encoding@^1.0.3:
|
||||
dependencies:
|
||||
iconv-lite "0.4.24"
|
||||
|
||||
whatwg-mimetype@^2.1.0, whatwg-mimetype@^2.2.0:
|
||||
whatwg-mimetype@^2.1.0, whatwg-mimetype@^2.2.0, whatwg-mimetype@^2.3.0:
|
||||
version "2.3.0"
|
||||
resolved "https://registry.yarnpkg.com/whatwg-mimetype/-/whatwg-mimetype-2.3.0.tgz#3d4b1e0312d2079879f826aff18dbeeca5960fbf"
|
||||
integrity sha512-M4yMwr6mAnQz76TbJm914+gPpB/nCwvZbJU28cUD6dR004SAxDLOOSUaB1JDRqLtaOV/vi0IC5lEAGFgrjGv/g==
|
||||
|
||||
Reference in New Issue
Block a user