Skip to content

Commit

Permalink
[dagster-airlift] Scheduling migration guide from Airflow to Dagster
Browse files Browse the repository at this point in the history
  • Loading branch information
dpeng817 committed Nov 24, 2024
1 parent 3073911 commit 10abc83
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -257,7 +257,7 @@ export AIRFLOW_CONN_AWS_DEFAULT='aws://YOUR_AWS_ACCESS_KEY_ID:YOUR_AWS_SECRET_AC

Here's an example of using an Airflow Hook with a set-up Airflow connection to interact with S3:

```python file=/integrations/airlift/equivalents/airflow_hook.py
```python file=/integrations/airlift/equivalents/airflow_hook.py startafter=start_ex endbefore=end_ex
from datetime import datetime, timedelta

from airflow import DAG
Expand Down
Empty file.
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
# type: ignore
# start_ex
from datetime import datetime, timedelta

from airflow import DAG
Expand All @@ -18,3 +20,4 @@ def upload_customers_data() -> None:
task_id="s3_operations",
python_callable=upload_customers_data,
)
# end_ex

0 comments on commit 10abc83

Please sign in to comment.