File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -63,10 +63,12 @@ def main():
63
63
64
64
if os .getenv ('DEPLOYMENT' , 'staging' ) == "prod" :
65
65
call (f'{ mj_cmd } { mj_ext } --days { DAY } | pv | gzip > build_day.json.gz' )
66
- call (f'{ bq_cmd } { bq_ext } kubernetes-public:k8s_infra_kettle.day build_day.json.gz schema.json' )
66
+ call (f'{ bq_cmd } { bq_ext } ' \
67
+ f'kubernetes-public:k8s_infra_kettle.day build_day.json.gz schema.json' )
67
68
68
69
call (f'{ mj_cmd } { mj_ext } --days { WEEK } | pv | gzip > build_week.json.gz' )
69
- call (f'{ bq_cmd } { bq_ext } kubernetes-public:k8s_infra_kettle.week build_week.json.gz schema.json' )
70
+ call (f'{ bq_cmd } { bq_ext } ' \
71
+ f'kubernetes-public:k8s_infra_kettle.week build_week.json.gz schema.json' )
70
72
71
73
# TODO: (MushuEE) #20024, remove 30 day limit once issue with all uploads is found
72
74
call (f'{ mj_cmd } --days { MONTH } | pv | gzip > build_all.json.gz' )
@@ -77,7 +79,8 @@ def main():
77
79
f'--tables all:{ MONTH } day:{ DAY } week:{ WEEK } --stop_at=1' )
78
80
else :
79
81
call (f'{ mj_cmd } | pv | gzip > build_staging.json.gz' )
80
- call (f'{ bq_cmd } kubernetes-public:k8s_infra_kettle.staging build_staging.json.gz schema.json' )
82
+ call (f'{ bq_cmd } kubernetes-public:k8s_infra_kettle.staging ' \
83
+ f'build_staging.json.gz schema.json' )
81
84
call (f'python3 stream.py --poll { SUB_PATH } ' \
82
85
f'--dataset kubernetes-public:k8s_infra_kettle --tables staging:0 --stop_at=1' )
83
86
You can’t perform that action at this time.
0 commit comments