Skip to content

Commit 47c6fd5

Browse files
Lee-WLee-W
committed
style: fix style error
1 parent 7200afa commit 47c6fd5

File tree

21 files changed

+28
-39
lines changed

21 files changed

+28
-39
lines changed

‎.gitignore

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -106,6 +106,8 @@ target/
106106

107107
# mkdocs
108108
site
109-
-h
110-
logs
109+
110+
# airflow
111+
sqlite/
112+
logs/
111113
simple_auth_manager_passwords.json.generated

‎dags/app/channel_reminder/dag.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,10 +4,8 @@
44

55
from datetime import datetime, timedelta
66

7+
from airflow.sdk import Variable, dag, task
78
from app import discord
8-
from airflow.sdk import dag
9-
from airflow.sdk import task
10-
from airflow.sdk import Variable
119

1210
DEFAULT_ARGS = {
1311
"owner": "David Jr.",

‎dags/app/finance_bot/dag.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44

55
from datetime import datetime, timedelta
66

7+
from airflow.sdk import Variable, dag, task
78
from app import discord
89
from app.finance_bot.udf import (
910
df_difference,
@@ -12,9 +13,6 @@
1213
refine_diff_df_to_string,
1314
write_to_bigquery,
1415
)
15-
from airflow.sdk import dag
16-
from airflow.sdk import task
17-
from airflow.sdk import Variable
1816

1917
DEFAULT_ARGS = {
2018
"owner": "CHWan",

‎dags/app/finance_bot/udf.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,8 @@
33
import numpy as np
44
import pandas as pd
55
import pygsheets
6-
from google.cloud import bigquery
76
from airflow.sdk import Variable
7+
from google.cloud import bigquery
88

99

1010
def df_difference(df_xls: pd.DataFrame, df_bigquery: pd.DataFrame) -> pd.DataFrame:

‎dags/app/proposal_reminder/dag.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,11 +4,9 @@
44

55
from datetime import datetime, timedelta
66

7+
from airflow.sdk import Variable, dag, task
78
from app import discord
89
from app.proposal_reminder.udf import get_proposal_summary
9-
from airflow.sdk import dag
10-
from airflow.sdk import task
11-
from airflow.sdk import Variable
1210

1311
DEFAULT_ARGS = {
1412
"owner": "Henry Lee",

‎dags/app/team_registration_bot/dag.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,14 +4,12 @@
44

55
from datetime import datetime, timedelta
66

7+
from airflow.sdk import Variable, dag, task
78
from app import discord
89
from app.team_registration_bot.udf import (
910
_compose_discord_msg,
1011
_get_statistics_from_bigquery,
1112
)
12-
from airflow.sdk import dag
13-
from airflow.sdk import task
14-
from airflow.sdk import Variable
1513

1614
DEFAULT_ARGS = {
1715
"owner": "David Jr.",

‎dags/app/twitter_post_notification_bot/dag.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,10 +6,8 @@
66

77
import requests
88
from airflow import settings
9+
from airflow.sdk import Variable, dag, task
910
from sqlalchemy.orm import sessionmaker
10-
from airflow.sdk import dag
11-
from airflow.sdk import task
12-
from airflow.sdk import Variable
1311

1412
DEFAULT_ARGS = {
1513
"owner": "David Jr.",

‎dags/ods/fb_post_insights/dag.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
"""
22
Scrape Facebook posts and insights data, save to BigQuery
33
"""
4+
45
from datetime import datetime, timedelta
56

7+
from airflow.sdk import dag, task
68
from utils.posts_insights.facebook import FacebookPostsInsightsParser
7-
from airflow.sdk import dag
8-
from airflow.sdk import task
99

1010
DEFAULT_ARGS = {
1111
"owner": "CHWan",

‎dags/ods/ig_post_insights/dags.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
"""
22
Scrape Instagram posts and insights data, save to BigQuery
33
"""
4+
45
from datetime import datetime, timedelta
56

7+
from airflow.sdk import dag, task
68
from utils.posts_insights.instagram import InstagramPostsInsightsParser
7-
from airflow.sdk import dag
8-
from airflow.sdk import task
99

1010
DEFAULT_ARGS = {
1111
"owner": "Angus Yang",

‎dags/ods/kktix_ticket_orders/kktix_dag.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,8 @@
44

55
from datetime import datetime, timedelta
66

7+
from airflow.sdk import dag, task
78
from ods.kktix_ticket_orders.udfs import bigquery_loader, kktix_api
8-
from airflow.sdk import dag
9-
from airflow.sdk import task
109

1110
DEFAULT_ARGS = {
1211
"owner": "David Jr.",

‎dags/ods/kktix_ticket_orders/kktix_refund_dag.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,8 @@
44

55
from datetime import datetime, timedelta
66

7+
from airflow.sdk import dag, task
78
from ods.kktix_ticket_orders.udfs import kktix_refund
8-
from airflow.sdk import dag
9-
from airflow.sdk import task
109

1110
DEFAULT_ARGS = {
1211
"owner": "Henry Lee",

‎dags/ods/kktix_ticket_orders/udfs/kktix_api.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,9 @@
44
import requests
55
import tenacity
66
from airflow.providers.http.hooks.http import HttpHook
7+
from airflow.sdk import Variable
78
from dateutil.parser import parse
89
from ods.kktix_ticket_orders.udfs import kktix_loader, kktix_transformer
9-
from airflow.sdk import Variable
1010

1111
SCHEDULE_INTERVAL_SECONDS: int = 3600
1212
HTTP_HOOK = HttpHook(http_conn_id="kktix_api", method="GET")

‎dags/ods/linkedin_post_insights/dags.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
"""
22
Scrape LinkedIn posts and insights data, save to BigQuery
33
"""
4+
45
from datetime import datetime, timedelta
56

7+
from airflow.sdk import dag, task
68
from utils.posts_insights.linkedin import LinkedinPostsInsightsParser
7-
from airflow.sdk import dag
8-
from airflow.sdk import task
99

1010
DEFAULT_ARGS = {
1111
"owner": "Angus Yang",

‎dags/ods/twitter_post_insights/dags.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
"""
22
Scrape X (Twitter) posts and insights data, save to BigQuery
33
"""
4+
45
from datetime import datetime, timedelta
56

7+
from airflow.sdk import dag, task
68
from utils.posts_insights.twitter import TwitterPostsInsightsParser
7-
from airflow.sdk import dag
8-
from airflow.sdk import task
99

1010
DEFAULT_ARGS = {
1111
"owner": "Henry Lee",

‎dags/ods/youtube/dags/dag.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,8 @@
44

55
from datetime import datetime, timedelta
66

7+
from airflow.sdk import dag, task
78
from ods.youtube.udfs import youtube_api
8-
from airflow.sdk import dag
9-
from airflow.sdk import task
109

1110
DEFAULT_ARGS = {
1211
"owner": "David Jr.",

‎dags/ods/youtube/udfs/youtube_api.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,9 @@
55
import pandas as pd
66
from airflow import macros
77
from airflow.providers.http.hooks.http import HttpHook
8+
from airflow.sdk import Variable
89
from google.cloud import bigquery
910
from utils.hook_related import RETRY_ARGS
10-
from airflow.sdk import Variable
1111

1212
# channel id of YouTube is public to everyone, so it's okay to commit this ID into git
1313
CHANNEL_ID = "UCHLnNgRnfGYDzPCCH8qGbQw"

‎dags/utils/posts_insights/facebook.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,12 @@
22
from datetime import datetime
33

44
import requests
5+
from airflow.sdk import Variable
56
from google.cloud import bigquery
67
from utils.posts_insights.base import (
78
CREATE_POST_TABLE_SQL_TEMPLATE,
89
BasePostsInsightsParser,
910
)
10-
from airflow.sdk import Variable
1111

1212
logger = logging.getLogger(__name__)
1313

‎dags/utils/posts_insights/instagram.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,12 @@
22
from datetime import datetime
33

44
import requests
5+
from airflow.sdk import Variable
56
from utils.posts_insights.base import (
67
CREATE_INSIGHT_TABLE_SQL_TEMPLATE,
78
CREATE_POST_TABLE_SQL_TEMPLATE,
89
BasePostsInsightsParser,
910
)
10-
from airflow.sdk import Variable
1111

1212
logger = logging.getLogger(__name__)
1313

‎dags/utils/posts_insights/linkedin.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,12 @@
22
from datetime import datetime
33

44
import requests
5+
from airflow.sdk import Variable
56
from utils.posts_insights.base import (
67
CREATE_INSIGHT_TABLE_SQL_TEMPLATE,
78
CREATE_POST_TABLE_SQL_TEMPLATE,
89
BasePostsInsightsParser,
910
)
10-
from airflow.sdk import Variable
1111

1212
logger = logging.getLogger(__name__)
1313

‎dags/utils/posts_insights/twitter.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,12 @@
22
from datetime import datetime
33

44
import requests
5+
from airflow.sdk import Variable
56
from utils.posts_insights.base import (
67
CREATE_INSIGHT_TABLE_SQL_TEMPLATE,
78
CREATE_POST_TABLE_SQL_TEMPLATE,
89
BasePostsInsightsParser,
910
)
10-
from airflow.sdk import Variable
1111

1212
logger = logging.getLogger(__name__)
1313

‎tests/conftest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import pytest
22

33

4-
@pytest.fixture()
4+
@pytest.fixture
55
def kktix_api_data():
66
return [
77
{

0 commit comments

Comments
 (0)