mirror of
https://github.com/apache/superset.git
synced 2026-04-21 09:04:38 +00:00
7b3095d6ff
* Fix examples charts/dashboards and refactor * pylinting * Fix pylint * Lint the refactor * Rebased
47 lines
1.2 KiB
Python
47 lines
1.2 KiB
Python
"""Loads datasets, dashboards and slices in a new superset instance"""
|
|
# pylint: disable=C,R,W
|
|
import json
|
|
import os
|
|
|
|
from superset import app, db
|
|
from superset.connectors.connector_registry import ConnectorRegistry
|
|
from superset.models import core as models
|
|
|
|
# Shortcuts
|
|
DB = models.Database
|
|
Slice = models.Slice
|
|
Dash = models.Dashboard
|
|
|
|
TBL = ConnectorRegistry.sources['table']
|
|
|
|
config = app.config
|
|
|
|
DATA_FOLDER = os.path.join(config.get('BASE_DIR'), 'data')
|
|
|
|
misc_dash_slices = set() # slices assembled in a 'Misc Chart' dashboard
|
|
|
|
|
|
def update_slice_ids(layout_dict, slices):
|
|
charts = [
|
|
component for component in layout_dict.values()
|
|
if isinstance(component, dict) and component['type'] == 'CHART'
|
|
]
|
|
sorted_charts = sorted(charts, key=lambda k: k['meta']['chartId'])
|
|
for i, chart_component in enumerate(sorted_charts):
|
|
if i < len(slices):
|
|
chart_component['meta']['chartId'] = int(slices[i].id)
|
|
|
|
|
|
def merge_slice(slc):
|
|
o = db.session.query(Slice).filter_by(slice_name=slc.slice_name).first()
|
|
if o:
|
|
db.session.delete(o)
|
|
db.session.add(slc)
|
|
db.session.commit()
|
|
|
|
|
|
def get_slice_json(defaults, **kwargs):
|
|
d = defaults.copy()
|
|
d.update(kwargs)
|
|
return json.dumps(d, indent=4, sort_keys=True)
|