Merge pull request #2781 from bolkedebruin/AIRFLOW-1802
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/d9905310 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/d9905310 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/d9905310 Branch: refs/heads/master Commit: d99053106e58ec377333c64f68ee84ed1dcdf61c Parents: d8115e9 f1ab56c Author: Bolke de Bruin <[email protected]> Authored: Mon Nov 27 21:39:28 2017 +0100 Committer: Bolke de Bruin <[email protected]> Committed: Mon Nov 27 21:39:28 2017 +0100 ---------------------------------------------------------------------- airflow/api/common/experimental/mark_tasks.py | 9 +- airflow/api/common/experimental/trigger_dag.py | 6 +- airflow/config_templates/default_airflow.cfg | 10 +- airflow/jobs.py | 80 +++---- .../0e2a74e0fc9f_add_time_zone_awareness.py | 213 +++++++++++++++++++ airflow/models.py | 160 +++++++++----- airflow/operators/dagrun_operator.py | 5 +- airflow/operators/latest_only_operator.py | 4 +- airflow/operators/sensors.py | 10 +- airflow/settings.py | 29 +++ airflow/ti_deps/deps/not_in_retry_period_dep.py | 4 +- airflow/ti_deps/deps/runnable_exec_date_dep.py | 4 +- airflow/utils/dag_processing.py | 8 +- airflow/utils/dates.py | 36 ++-- airflow/utils/timezone.py | 152 +++++++++++++ airflow/www/api/experimental/endpoints.py | 16 +- airflow/www/forms.py | 4 +- airflow/www/utils.py | 14 +- airflow/www/views.py | 105 ++++++--- docs/index.rst | 1 + docs/timezone.rst | 143 +++++++++++++ scripts/ci/requirements.txt | 1 + setup.py | 4 + tests/api/client/test_local_client.py | 31 +-- tests/contrib/operators/test_druid_operator.py | 6 +- tests/contrib/operators/test_fs_operator.py | 5 +- .../operators/test_jira_operator_test.py | 5 +- tests/contrib/operators/test_sftp_operator.py | 21 +- .../operators/test_spark_submit_operator.py | 9 +- tests/contrib/operators/test_ssh_operator.py | 12 +- tests/contrib/sensors/test_jira_sensor_test.py | 6 +- tests/contrib/sensors/test_redis_sensor.py | 4 +- tests/core.py | 32 +-- tests/dags/test_cli_triggered_dags.py | 4 +- tests/executors/dask_executor.py | 13 +- tests/impersonation.py | 2 +- tests/jobs.py | 33 +-- tests/models.py | 91 ++++---- tests/operators/latest_only_operator.py | 51 ++--- tests/operators/operators.py | 7 +- tests/operators/python_operator.py | 11 +- tests/operators/sensors.py | 8 +- tests/operators/subdag_operator.py | 5 +- tests/operators/test_virtualenv_operator.py | 11 +- .../deps/test_not_in_retry_period_dep.py | 3 +- .../ti_deps/deps/test_runnable_exec_date_dep.py | 3 +- tests/utils/log/test_file_processor_handler.py | 10 +- tests/utils/log/test_s3_task_handler.py | 2 +- tests/utils/test_dates.py | 14 +- tests/utils/test_log_handlers.py | 2 +- tests/utils/test_timezone.py | 67 ++++++ tests/www/api/experimental/test_endpoints.py | 9 +- tests/www/test_views.py | 4 +- 53 files changed, 1104 insertions(+), 395 deletions(-) ----------------------------------------------------------------------
