This is an automated email from the ASF dual-hosted git repository.
gopidesu pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 5886016243d Prepare docs for Oct 2nd wave of providers RC2 (#43540)
add 06088a3abcb Standard provider python operator (#42081)
No new revisions were added by this update.
Summary of changes:
.pre-commit-config.yaml | 2 +-
airflow/decorators/branch_external_python.py | 2 +-
airflow/decorators/branch_python.py | 2 +-
airflow/decorators/branch_virtualenv.py | 2 +-
airflow/decorators/external_python.py | 2 +-
airflow/decorators/python.py | 2 +-
airflow/decorators/python_virtualenv.py | 2 +-
airflow/decorators/sensor.py | 2 +-
airflow/decorators/short_circuit.py | 2 +-
.../example_asset_alias_with_no_taskflow.py | 2 +-
airflow/example_dags/example_branch_operator.py | 4 +-
.../example_branch_operator_decorator.py | 2 +-
.../example_python_context_decorator.py | 6 +-
.../example_python_context_operator.py | 12 ++--
airflow/example_dags/example_python_decorator.py | 2 +-
airflow/example_dags/example_python_operator.py | 2 +-
airflow/example_dags/example_sensors.py | 2 +-
.../example_dags/example_short_circuit_operator.py | 2 +-
airflow/example_dags/tutorial_dag.py | 2 +-
.../tutorial_taskflow_api_virtualenv.py | 2 +-
.../example_dags/tutorial_taskflow_templates.py | 2 +-
dev/breeze/src/airflow_breeze/utils/run_tests.py | 10 +--
.../src/airflow_breeze/utils/selective_checks.py | 4 +-
.../tests/test_pytest_args_for_test_types.py | 10 +--
dev/breeze/tests/test_selective_checks.py | 40 +++++------
dev/perf/dags/sql_perf_dag.py | 2 +-
.../guides/user.rst | 4 +-
.../dynamic-task-mapping.rst | 2 +-
docs/apache-airflow/best-practices.rst | 16 ++---
docs/apache-airflow/core-concepts/dags.rst | 2 +-
docs/apache-airflow/core-concepts/operators.rst | 4 +-
docs/apache-airflow/howto/operator/python.rst | 24 +++----
docs/apache-airflow/operators-and-hooks-ref.rst | 4 +-
docs/apache-airflow/tutorial/taskflow.rst | 2 +-
docs/exts/templates/openlineage.rst.jinja2 | 2 +-
generated/provider_dependencies.json | 15 ++--
.../providers/amazon/aws/operators/appflow.py | 2 +-
.../airflow/providers/apache/beam/hooks/beam.py | 2 +-
.../providers/apache/spark/decorators/pyspark.py | 2 +-
.../celery/executors/celery_executor_utils.py | 5 +-
.../providers/common/compat/standard}/__init__.py | 0
.../providers/common/compat/standard/operators.py | 54 +++++++++++++++
.../{security/permissions.py => standard/utils.py} | 11 +--
.../airflow/providers/docker/decorators/docker.py | 4 +-
.../edge/example_dags/integration_test.py | 2 +-
.../google/cloud/utils/mlengine_operator_utils.py | 2 +-
.../airflow/providers/openlineage/provider.yaml | 2 +-
.../providers/snowflake/operators/snowpark.py | 2 +-
.../providers/standard}/operators/python.py | 81 ++++++++--------------
.../src/airflow/providers/standard/provider.yaml | 3 +-
.../airflow/providers/standard}/sensors/python.py | 0
.../airflow/providers/standard/utils}/__init__.py | 0
.../providers/standard}/utils/python_virtualenv.py | 11 ---
.../utils/python_virtualenv_script.jinja2 | 4 +-
.../kubernetes/log_handlers/test_log_handlers.py | 3 +-
.../cloud/utils/test_mlengine_operator_utils.py | 3 +-
.../tests/openlineage/extractors/test_base.py | 4 +-
.../tests/openlineage/extractors/test_manager.py | 3 +-
.../tests/openlineage/extractors/test_python.py | 3 +-
.../tests/openlineage/plugins/test_listener.py | 3 +-
providers/tests/openlineage/plugins/test_utils.py | 4 +-
providers/tests/openlineage/utils/test_utils.py | 13 ++--
.../tests/standard}/operators/test_python.py | 44 +++++++-----
.../tests/standard}/sensors/test_python.py | 4 +-
.../tests/standard/utils}/__init__.py | 0
.../standard}/utils/test_python_virtualenv.py | 10 +--
providers/tests/system/amazon/aws/example_s3.py | 2 +-
.../tests/system/amazon/aws/example_sagemaker.py | 2 +-
.../apache/kafka/example_dag_event_listener.py | 6 +-
.../system/apache/kafka/example_dag_hello_kafka.py | 8 +--
.../system/docker/example_docker_copy_data.py | 2 +-
.../elasticsearch/example_elasticsearch_query.py | 2 +-
.../cloud/cloud_batch/example_cloud_batch.py | 2 +-
.../google/cloud/cloud_run/example_cloud_run.py | 2 +-
.../system/google/cloud/gcs/example_gcs_to_gcs.py | 2 +-
tests/core/test_core.py | 2 +-
tests/core/test_example_dags_system.py | 2 +-
tests/core/test_sentry.py | 2 +-
tests/dags/test_assets.py | 2 +-
tests/dags/test_cli_triggered_dags.py | 2 +-
tests/dags/test_dag_xcom_openlineage.py | 2 +-
tests/dags/test_dagrun_fast_follow.py | 2 +-
tests/dags/test_future_start_date.py | 2 +-
tests/dags/test_invalid_param.py | 2 +-
tests/dags/test_invalid_param2.py | 2 +-
tests/dags/test_invalid_param3.py | 2 +-
tests/dags/test_invalid_param4.py | 2 +-
tests/dags/test_logging_in_dag.py | 2 +-
tests/dags/test_mapped_classic.py | 2 +-
tests/dags/test_mark_state.py | 2 +-
tests/dags/test_on_failure_callback.py | 2 +-
tests/dags/test_task_view_type_check.py | 2 +-
tests/dags/test_valid_param.py | 2 +-
tests/dags/test_valid_param2.py | 2 +-
tests/dags_corrupted/test_impersonation_custom.py | 2 +-
tests/decorators/test_python.py | 2 +-
tests/jobs/test_local_task_job.py | 2 +-
tests/jobs/test_triggerer_job.py | 2 +-
tests/models/test_backfill.py | 2 +-
tests/models/test_baseoperatormeta.py | 2 +-
tests/models/test_cleartasks.py | 2 +-
tests/models/test_dag.py | 2 +-
tests/models/test_dagbag.py | 2 +-
tests/models/test_dagrun.py | 4 +-
tests/models/test_mappedoperator.py | 6 +-
tests/models/test_renderedtifields.py | 2 +-
tests/models/test_taskinstance.py | 6 +-
tests/models/test_xcom_arg.py | 2 +-
tests/sensors/test_external_task_sensor.py | 2 +-
tests/serialization/test_serialized_objects.py | 2 +-
.../deps/test_not_previously_skipped_dep.py | 2 +-
tests/utils/log/test_log_reader.py | 2 +-
tests/utils/test_db_cleanup.py | 2 +-
tests/utils/test_dot_renderer.py | 6 +-
tests/utils/test_edgemodifier.py | 2 +-
tests/utils/test_log_handlers.py | 2 +-
tests/utils/test_task_group.py | 3 +-
tests/www/views/test_views_rendered.py | 3 +-
tests_common/test_utils/compat.py | 4 ++
119 files changed, 326 insertions(+), 288 deletions(-)
copy {airflow/api_connexion =>
providers/src/airflow/providers/common/compat/standard}/__init__.py (100%)
create mode 100644
providers/src/airflow/providers/common/compat/standard/operators.py
copy providers/src/airflow/providers/common/compat/{security/permissions.py =>
standard/utils.py} (69%)
rename {airflow =>
providers/src/airflow/providers/standard}/operators/python.py (95%)
rename {airflow => providers/src/airflow/providers/standard}/sensors/python.py
(100%)
copy {airflow/api_connexion =>
providers/src/airflow/providers/standard/utils}/__init__.py (100%)
rename {airflow =>
providers/src/airflow/providers/standard}/utils/python_virtualenv.py (93%)
rename {airflow =>
providers/src/airflow/providers/standard}/utils/python_virtualenv_script.jinja2
(95%)
rename {tests => providers/tests/standard}/operators/test_python.py (98%)
rename {tests => providers/tests/standard}/sensors/test_python.py (95%)
copy {airflow/api_connexion => providers/tests/standard/utils}/__init__.py
(100%)
rename {tests => providers/tests/standard}/utils/test_python_virtualenv.py
(92%)