mirror of
https://github.com/apache/superset.git
synced 2024-09-18 11:39:49 -04:00
1dd4d7a587
* Add license headers * reabased * lint * Removing licenses from vendors folder
385 lines
14 KiB
Python
385 lines
14 KiB
Python
# Licensed to the Apache Software Foundation (ASF) under one
|
|
# or more contributor license agreements. See the NOTICE file
|
|
# distributed with this work for additional information
|
|
# regarding copyright ownership. The ASF licenses this file
|
|
# to you under the Apache License, Version 2.0 (the
|
|
# "License"); you may not use this file except in compliance
|
|
# with the License. You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing,
|
|
# software distributed under the License is distributed on an
|
|
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
# KIND, either express or implied. See the License for the
|
|
# specific language governing permissions and limitations
|
|
# under the License.
|
|
from datetime import datetime, timedelta
|
|
import unittest
|
|
|
|
from flask_babel import gettext as __
|
|
from mock import Mock, patch, PropertyMock
|
|
from selenium.common.exceptions import WebDriverException
|
|
|
|
from superset import app, db
|
|
from superset.models.core import Dashboard, Slice
|
|
from superset.models.schedules import (
|
|
DashboardEmailSchedule,
|
|
EmailDeliveryType,
|
|
SliceEmailReportFormat,
|
|
SliceEmailSchedule,
|
|
)
|
|
from superset.tasks.schedules import (
|
|
create_webdriver,
|
|
deliver_dashboard,
|
|
deliver_slice,
|
|
next_schedules,
|
|
)
|
|
from .utils import read_fixture
|
|
|
|
|
|
class SchedulesTestCase(unittest.TestCase):
|
|
|
|
RECIPIENTS = 'recipient1@superset.com, recipient2@superset.com'
|
|
BCC = 'bcc@superset.com'
|
|
CSV = read_fixture('trends.csv')
|
|
|
|
@classmethod
|
|
def setUpClass(cls):
|
|
cls.common_data = dict(
|
|
active=True,
|
|
crontab='* * * * *',
|
|
recipients=cls.RECIPIENTS,
|
|
deliver_as_group=True,
|
|
delivery_type=EmailDeliveryType.inline,
|
|
)
|
|
|
|
# Pick up a random slice and dashboard
|
|
slce = db.session.query(Slice).all()[0]
|
|
dashboard = db.session.query(Dashboard).all()[0]
|
|
|
|
dashboard_schedule = DashboardEmailSchedule(**cls.common_data)
|
|
dashboard_schedule.dashboard_id = dashboard.id
|
|
dashboard_schedule.user_id = 1
|
|
db.session.add(dashboard_schedule)
|
|
|
|
slice_schedule = SliceEmailSchedule(**cls.common_data)
|
|
slice_schedule.slice_id = slce.id
|
|
slice_schedule.user_id = 1
|
|
slice_schedule.email_format = SliceEmailReportFormat.data
|
|
|
|
db.session.add(slice_schedule)
|
|
db.session.commit()
|
|
|
|
cls.slice_schedule = slice_schedule.id
|
|
cls.dashboard_schedule = dashboard_schedule.id
|
|
|
|
@classmethod
|
|
def tearDownClass(cls):
|
|
db.session.query(SliceEmailSchedule).filter_by(id=cls.slice_schedule).delete()
|
|
db.session.query(DashboardEmailSchedule).filter_by(
|
|
id=cls.dashboard_schedule).delete()
|
|
db.session.commit()
|
|
|
|
def test_crontab_scheduler(self):
|
|
crontab = '* * * * *'
|
|
|
|
start_at = datetime.now().replace(microsecond=0, second=0, minute=0)
|
|
stop_at = start_at + timedelta(seconds=3600)
|
|
|
|
# Fire off the task every minute
|
|
schedules = list(next_schedules(crontab, start_at, stop_at, resolution=0))
|
|
|
|
self.assertEqual(schedules[0], start_at)
|
|
self.assertEqual(schedules[-1], stop_at - timedelta(seconds=60))
|
|
self.assertEqual(len(schedules), 60)
|
|
|
|
# Fire off the task every 10 minutes, controlled via resolution
|
|
schedules = list(next_schedules(crontab, start_at, stop_at, resolution=10 * 60))
|
|
|
|
self.assertEqual(schedules[0], start_at)
|
|
self.assertEqual(schedules[-1], stop_at - timedelta(seconds=10 * 60))
|
|
self.assertEqual(len(schedules), 6)
|
|
|
|
# Fire off the task every 12 minutes, controlled via resolution
|
|
schedules = list(next_schedules(crontab, start_at, stop_at, resolution=12 * 60))
|
|
|
|
self.assertEqual(schedules[0], start_at)
|
|
self.assertEqual(schedules[-1], stop_at - timedelta(seconds=12 * 60))
|
|
self.assertEqual(len(schedules), 5)
|
|
|
|
def test_wider_schedules(self):
|
|
crontab = '*/15 2,10 * * *'
|
|
|
|
for hour in range(0, 24):
|
|
start_at = datetime.now().replace(
|
|
microsecond=0, second=0, minute=0, hour=hour)
|
|
stop_at = start_at + timedelta(seconds=3600)
|
|
schedules = list(next_schedules(crontab, start_at, stop_at, resolution=0))
|
|
|
|
if hour in (2, 10):
|
|
self.assertEqual(len(schedules), 4)
|
|
else:
|
|
self.assertEqual(len(schedules), 0)
|
|
|
|
def test_complex_schedule(self):
|
|
# Run the job on every Friday of March and May
|
|
# On these days, run the job at
|
|
# 5:10 pm
|
|
# 5:11 pm
|
|
# 5:12 pm
|
|
# 5:13 pm
|
|
# 5:14 pm
|
|
# 5:15 pm
|
|
# 5:25 pm
|
|
# 5:28 pm
|
|
# 5:31 pm
|
|
# 5:34 pm
|
|
# 5:37 pm
|
|
# 5:40 pm
|
|
crontab = '10-15,25-40/3 17 * 3,5 5'
|
|
start_at = datetime.strptime('2018/01/01', '%Y/%m/%d')
|
|
stop_at = datetime.strptime('2018/12/31', '%Y/%m/%d')
|
|
|
|
schedules = list(next_schedules(crontab, start_at, stop_at, resolution=60))
|
|
self.assertEqual(len(schedules), 108)
|
|
fmt = '%Y-%m-%d %H:%M:%S'
|
|
self.assertEqual(schedules[0], datetime.strptime('2018-03-02 17:10:00', fmt))
|
|
self.assertEqual(schedules[-1], datetime.strptime('2018-05-25 17:40:00', fmt))
|
|
self.assertEqual(schedules[59], datetime.strptime('2018-03-30 17:40:00', fmt))
|
|
self.assertEqual(schedules[60], datetime.strptime('2018-05-04 17:10:00', fmt))
|
|
|
|
@patch('superset.tasks.schedules.firefox.webdriver.WebDriver')
|
|
def test_create_driver(self, mock_driver_class):
|
|
mock_driver = Mock()
|
|
mock_driver_class.return_value = mock_driver
|
|
mock_driver.find_elements_by_id.side_effect = [True, False]
|
|
|
|
create_webdriver()
|
|
create_webdriver()
|
|
mock_driver.add_cookie.assert_called_once()
|
|
|
|
@patch('superset.tasks.schedules.firefox.webdriver.WebDriver')
|
|
@patch('superset.tasks.schedules.send_email_smtp')
|
|
@patch('superset.tasks.schedules.time')
|
|
def test_deliver_dashboard_inline(self, mtime, send_email_smtp, driver_class):
|
|
element = Mock()
|
|
driver = Mock()
|
|
mtime.sleep.return_value = None
|
|
|
|
driver_class.return_value = driver
|
|
|
|
# Ensure that we are able to login with the driver
|
|
driver.find_elements_by_id.side_effect = [True, False]
|
|
driver.find_element_by_class_name.return_value = element
|
|
element.screenshot_as_png = read_fixture('sample.png')
|
|
|
|
schedule = db.session.query(DashboardEmailSchedule).filter_by(
|
|
id=self.dashboard_schedule).all()[0]
|
|
|
|
deliver_dashboard(schedule)
|
|
mtime.sleep.assert_called_once()
|
|
driver.screenshot.assert_not_called()
|
|
send_email_smtp.assert_called_once()
|
|
|
|
@patch('superset.tasks.schedules.firefox.webdriver.WebDriver')
|
|
@patch('superset.tasks.schedules.send_email_smtp')
|
|
@patch('superset.tasks.schedules.time')
|
|
def test_deliver_dashboard_as_attachment(self, mtime, send_email_smtp, driver_class):
|
|
element = Mock()
|
|
driver = Mock()
|
|
mtime.sleep.return_value = None
|
|
|
|
driver_class.return_value = driver
|
|
|
|
# Ensure that we are able to login with the driver
|
|
driver.find_elements_by_id.side_effect = [True, False]
|
|
driver.find_element_by_id.return_value = element
|
|
driver.find_element_by_class_name.return_value = element
|
|
element.screenshot_as_png = read_fixture('sample.png')
|
|
|
|
schedule = db.session.query(DashboardEmailSchedule).filter_by(
|
|
id=self.dashboard_schedule).all()[0]
|
|
|
|
schedule.delivery_type = EmailDeliveryType.attachment
|
|
deliver_dashboard(schedule)
|
|
|
|
mtime.sleep.assert_called_once()
|
|
driver.screenshot.assert_not_called()
|
|
send_email_smtp.assert_called_once()
|
|
self.assertIsNone(send_email_smtp.call_args[1]['images'])
|
|
self.assertEquals(
|
|
send_email_smtp.call_args[1]['data']['screenshot.png'],
|
|
element.screenshot_as_png,
|
|
)
|
|
|
|
@patch('superset.tasks.schedules.firefox.webdriver.WebDriver')
|
|
@patch('superset.tasks.schedules.send_email_smtp')
|
|
@patch('superset.tasks.schedules.time')
|
|
def test_dashboard_chrome_like(self, mtime, send_email_smtp, driver_class):
|
|
# Test functionality for chrome driver which does not support
|
|
# element snapshots
|
|
element = Mock()
|
|
driver = Mock()
|
|
mtime.sleep.return_value = None
|
|
type(element).screenshot_as_png = PropertyMock(side_effect=WebDriverException)
|
|
|
|
driver_class.return_value = driver
|
|
|
|
# Ensure that we are able to login with the driver
|
|
driver.find_elements_by_id.side_effect = [True, False]
|
|
driver.find_element_by_id.return_value = element
|
|
driver.find_element_by_class_name.return_value = element
|
|
driver.screenshot.return_value = read_fixture('sample.png')
|
|
|
|
schedule = db.session.query(DashboardEmailSchedule).filter_by(
|
|
id=self.dashboard_schedule).all()[0]
|
|
|
|
deliver_dashboard(schedule)
|
|
mtime.sleep.assert_called_once()
|
|
driver.screenshot.assert_called_once()
|
|
send_email_smtp.assert_called_once()
|
|
|
|
self.assertEquals(send_email_smtp.call_args[0][0], self.RECIPIENTS)
|
|
self.assertEquals(
|
|
list(send_email_smtp.call_args[1]['images'].values())[0],
|
|
driver.screenshot.return_value,
|
|
)
|
|
|
|
@patch('superset.tasks.schedules.firefox.webdriver.WebDriver')
|
|
@patch('superset.tasks.schedules.send_email_smtp')
|
|
@patch('superset.tasks.schedules.time')
|
|
def test_deliver_email_options(self, mtime, send_email_smtp, driver_class):
|
|
element = Mock()
|
|
driver = Mock()
|
|
mtime.sleep.return_value = None
|
|
|
|
driver_class.return_value = driver
|
|
|
|
# Ensure that we are able to login with the driver
|
|
driver.find_elements_by_id.side_effect = [True, False]
|
|
driver.find_element_by_class_name.return_value = element
|
|
element.screenshot_as_png = read_fixture('sample.png')
|
|
|
|
schedule = db.session.query(DashboardEmailSchedule).filter_by(
|
|
id=self.dashboard_schedule).all()[0]
|
|
|
|
# Send individual mails to the group
|
|
schedule.deliver_as_group = False
|
|
|
|
# Set a bcc email address
|
|
app.config['EMAIL_REPORT_BCC_ADDRESS'] = self.BCC
|
|
|
|
deliver_dashboard(schedule)
|
|
mtime.sleep.assert_called_once()
|
|
driver.screenshot.assert_not_called()
|
|
|
|
self.assertEquals(send_email_smtp.call_count, 2)
|
|
self.assertEquals(send_email_smtp.call_args[1]['bcc'], self.BCC)
|
|
|
|
@patch('superset.tasks.schedules.firefox.webdriver.WebDriver')
|
|
@patch('superset.tasks.schedules.send_email_smtp')
|
|
@patch('superset.tasks.schedules.time')
|
|
def test_deliver_slice_inline_image(self, mtime, send_email_smtp, driver_class):
|
|
element = Mock()
|
|
driver = Mock()
|
|
mtime.sleep.return_value = None
|
|
|
|
driver_class.return_value = driver
|
|
|
|
# Ensure that we are able to login with the driver
|
|
driver.find_elements_by_id.side_effect = [True, False]
|
|
driver.find_element_by_class_name.return_value = element
|
|
element.screenshot_as_png = read_fixture('sample.png')
|
|
|
|
schedule = db.session.query(SliceEmailSchedule).filter_by(
|
|
id=self.slice_schedule).all()[0]
|
|
|
|
schedule.email_format = SliceEmailReportFormat.visualization
|
|
schedule.delivery_format = EmailDeliveryType.inline
|
|
|
|
deliver_slice(schedule)
|
|
mtime.sleep.assert_called_once()
|
|
driver.screenshot.assert_not_called()
|
|
send_email_smtp.assert_called_once()
|
|
|
|
self.assertEquals(
|
|
list(send_email_smtp.call_args[1]['images'].values())[0],
|
|
element.screenshot_as_png,
|
|
)
|
|
|
|
@patch('superset.tasks.schedules.firefox.webdriver.WebDriver')
|
|
@patch('superset.tasks.schedules.send_email_smtp')
|
|
@patch('superset.tasks.schedules.time')
|
|
def test_deliver_slice_attachment(self, mtime, send_email_smtp, driver_class):
|
|
element = Mock()
|
|
driver = Mock()
|
|
mtime.sleep.return_value = None
|
|
|
|
driver_class.return_value = driver
|
|
|
|
# Ensure that we are able to login with the driver
|
|
driver.find_elements_by_id.side_effect = [True, False]
|
|
driver.find_element_by_class_name.return_value = element
|
|
element.screenshot_as_png = read_fixture('sample.png')
|
|
|
|
schedule = db.session.query(SliceEmailSchedule).filter_by(
|
|
id=self.slice_schedule).all()[0]
|
|
|
|
schedule.email_format = SliceEmailReportFormat.visualization
|
|
schedule.delivery_type = EmailDeliveryType.attachment
|
|
|
|
deliver_slice(schedule)
|
|
mtime.sleep.assert_called_once()
|
|
driver.screenshot.assert_not_called()
|
|
send_email_smtp.assert_called_once()
|
|
|
|
self.assertEquals(
|
|
send_email_smtp.call_args[1]['data']['screenshot.png'],
|
|
element.screenshot_as_png,
|
|
)
|
|
|
|
@patch('superset.tasks.schedules.requests.get')
|
|
@patch('superset.tasks.schedules.send_email_smtp')
|
|
def test_deliver_slice_csv_attachment(self, send_email_smtp, get):
|
|
response = Mock()
|
|
get.return_value = response
|
|
response.raise_for_status.return_value = None
|
|
response.content = self.CSV
|
|
|
|
schedule = db.session.query(SliceEmailSchedule).filter_by(
|
|
id=self.slice_schedule).all()[0]
|
|
|
|
schedule.email_format = SliceEmailReportFormat.data
|
|
schedule.delivery_type = EmailDeliveryType.attachment
|
|
|
|
deliver_slice(schedule)
|
|
send_email_smtp.assert_called_once()
|
|
|
|
file_name = __('%(name)s.csv', name=schedule.slice.slice_name)
|
|
|
|
self.assertEquals(
|
|
send_email_smtp.call_args[1]['data'][file_name],
|
|
self.CSV,
|
|
)
|
|
|
|
@patch('superset.tasks.schedules.requests.get')
|
|
@patch('superset.tasks.schedules.send_email_smtp')
|
|
def test_deliver_slice_csv_inline(self, send_email_smtp, get):
|
|
response = Mock()
|
|
get.return_value = response
|
|
response.raise_for_status.return_value = None
|
|
response.content = self.CSV
|
|
|
|
schedule = db.session.query(SliceEmailSchedule).filter_by(
|
|
id=self.slice_schedule).all()[0]
|
|
|
|
schedule.email_format = SliceEmailReportFormat.data
|
|
schedule.delivery_type = EmailDeliveryType.inline
|
|
|
|
deliver_slice(schedule)
|
|
send_email_smtp.assert_called_once()
|
|
|
|
self.assertIsNone(send_email_smtp.call_args[1]['data'])
|
|
self.assertTrue('<table ' in send_email_smtp.call_args[0][2])
|