8000 Merge pull request #3 from magar51/import_update · magar51/python-docs-samples@ef085bb · GitHub
[go: up one dir, main page]
Skip to content

Commit ef085bb

Browse files
magar51GitHub Enterprise
magar51
authored and
GitHub Enterprise
committed
Merge pull request GoogleCloudPlatform#3 from magar51/import_update
Outdated bash operator import on Composer 2 Docs GoogleCloudPlatform#11433
2 parents 8fc1c1d + ed2f3c7 commit ef085bb

File tree

7 files changed

+10
-9
lines changed

7 files changed

+10
-9
lines changed

‎composer/airflow_1_samples/clear_file_system_caches_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818

1919
import airflow
2020
from airflow import DAG
21-
from airflow.operators.bash_operator import BashOperator
21+
from airflow.operators.bash import BashOperator
2222

2323
dag = DAG(
2424
"clear_file_system_caches_dag",

‎composer/airflow_1_samples/gke_operator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717

1818

1919
from airflow import models
20-
from airflow.operators.bash_operator import BashOperator
20+
from airflow.operators.bash import BashOperator
2121
from airflow.providers.google.cloud.operators.kubernetes_engine import (
2222
GKECreateClusterOperator,
2323
GKEDeleteClusterOperator,

‎composer/airflow_1_samples/grouping.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,8 @@
1414
# [START composer_grouping_airflow_1]
1515

1616
from airflow import DAG
17-
from airflow.operators.bash_operator import BashOperator
18-
from airflow.operators.dummy_operator import DummyOperator
17+
from airflow.operators.bash import BashOperator
18+
from airflow.operators.dummy import DummyOperator
1919
from airflow.utils.dates import days_ago
2020

2121
DAG_NAME = "all_tasks_in_one_dag"

‎composer/blog/gcp-tech-blog/unit-test-dags-cloud-build/dags/example_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616

1717
from airflow import models
1818

19-
from airflow.operators.bash_operator import BashOperator
19+
from airflow.operators.bash import BashOperator
2020
from airflow.operators.python_operator import PythonOperator
2121
from airflow.providers.google.cloud.operators.gcs import GCSCreateBucketOperator
2222
from airflow.providers.google.cloud.operators.gcs import GCSDeleteBucketOperator

‎composer/workflows/clear_file_system_caches_dag_composer_v1.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616

1717
import airflow
1818
from airflow import DAG
19-
from airflow.operators.bash_operator import BashOperator
19+
from airflow.operators.bash import BashOperator
2020

2121

2222
"""A dag that prevents memory leaks on scheduler and workers."""

‎composer/workflows/grouping.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,8 @@
1111
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1212
# See the License for the specific language governing permissions and
1313
# limitations under the License.
14+
# [START composer_grouping_airflow_1]
1415

15-
# [START composer_grouping]
1616
from airflow import DAG
1717
from airflow.operators.bash import BashOperator
1818
from airflow.operators.dummy import DummyOperator
@@ -38,4 +38,5 @@
3838
end = DummyOperator(task_id="end")
3939

4040
start >> [task_1, task_2] >> some_other_task >> [task_3, task_4] >> end
41-
# [END composer_grouping]
41+
42+
# [END composer_grouping_airflow_1]

‎composer/workflows/trigger_response_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
import datetime
1919

2020
import airflow
21-
from airflow.operators.bash_operator import BashOperator
21+
from airflow.operators.bash import BashOperator
2222

2323

2424
with airflow.DAG(

0 commit comments

Comments
 (0)
0