Skip to content
Merged
Changes from all commits
Commits
Show all changes
24 commits
Select commit Hold shift + click to select a range
a1c532e
[16185] Added LocalKubernetesExecutor to breeze supported executors
subkanthi Nov 22, 2021
6cbb506
Merge branch 'master' of github.com:subkanthi/airflow
subkanthi Nov 22, 2021
d16a343
Revert "[16185] Added LocalKubernetesExecutor to breeze supported exe…
subkanthi Nov 22, 2021
a336e17
Merge branch 'apache:main' into master
subkanthi Nov 30, 2021
382eedf
Merge branch 'apache:main' into master
subkanthi Dec 2, 2021
c3030fb
Merge branch 'apache:main' into master
subkanthi Dec 4, 2021
1c3c029
Merge branch 'apache:main' into master
subkanthi Dec 6, 2021
0eb6598
Merge branch 'apache:main' into master
subkanthi Dec 10, 2021
35a344e
Merge branch 'apache:main' into master
subkanthi Dec 12, 2021
8d47486
Merge branch 'apache:main' into master
subkanthi Dec 12, 2021
f450679
Merge branch 'apache:main' into master
subkanthi Dec 14, 2021
67c6f5e
Merge branch 'apache:main' into master
subkanthi Dec 14, 2021
a09d628
Merge branch 'apache:main' into master
subkanthi Dec 14, 2021
1568b72
Merge branch 'apache:main' into master
subkanthi Dec 15, 2021
a89daf1
Merge branch 'apache:main' into master
subkanthi Dec 16, 2021
3c24d50
Merge branch 'apache:main' into master
subkanthi Dec 18, 2021
874b0c2
Merge branch 'apache:main' into master
subkanthi Dec 19, 2021
c07aabf
Merge branch 'apache:main' into master
subkanthi Dec 20, 2021
0f385fc
Merge branch 'apache:main' into master
subkanthi Dec 20, 2021
8bab66c
Merge branch 'apache:main' into master
subkanthi Dec 21, 2021
9f34837
Merge branch 'apache:main' into master
subkanthi Dec 24, 2021
aabf41a
[20496] Removed hardcoded port 8080 and use the webserver port from conf
subkanthi Dec 26, 2021
38f6b75
Fix flake8 errors
subkanthi Dec 26, 2021
7b2ade7
Changed get WEB_SERVER_PORT
subkanthi Dec 27, 2021
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 7 additions & 1 deletion airflow/cli/commands/standalone_command.py
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,8 @@ def run(self):
command=["triggerer"],
env=env,
)

self.web_server_port = conf.getint('webserver', 'WEB_SERVER_PORT', fallback=8080)
# Run subcommand threads
for command in self.subcommands.values():
command.start()
Expand Down Expand Up @@ -206,7 +208,11 @@ def is_ready(self):
Detects when all Airflow components are ready to serve.
For now, it's simply time-based.
"""
return self.port_open(8080) and self.job_running(SchedulerJob) and self.job_running(TriggererJob)
return (
self.port_open(self.web_server_port)
and self.job_running(SchedulerJob)
and self.job_running(TriggererJob)
)

def port_open(self, port):
"""
Expand Down