Shipyard fix

This PS has to fix select tasks by id action.

Change-Id: I6503a48fb43793b2aae91dc7e5549f6bc3818d4a
This commit is contained in:
Sergiy Markin 2023-08-31 18:34:47 +00:00
parent 81066ae98f
commit e467af9338
2 changed files with 42 additions and 42 deletions

View File

@ -132,48 +132,43 @@ class AirflowDbAccess(DbAccess):
# used to merge into this query.
SELECT_TASKS_BY_ID = sqlalchemy.sql.text('''
SELECT
"task_id",
"dag_id",
"execution_date",
"dr"."run_id",
"start_date",
"end_date",
"duration",
"state",
"try_number",
"hostname",
"unixname",
"job_id",
"pool",
"queue",
"priority_weight",
"operator",
"queued_dttm",
"pid",
"max_tries"
FROM
task_instance ti
INNER JOIN
(
SELECT
"execution_date",
"run_id"
FROM
dag_run
GROUP BY
run_id,
execution_date
) dr
ON
ti.run_id=dr.run_id
WHERE
dag_id LIKE :dag_id
AND
execution_date = :execution_date
ORDER BY
priority_weight desc,
start_date
LIMIT 1
"task_id",
"dag_id",
"run_id",
"start_date",
"end_date",
"duration",
"state",
"try_number",
"hostname",
"unixname",
"job_id",
"pool",
"queue",
"priority_weight",
"operator",
"queued_dttm",
"pid",
"max_tries"
FROM
task_instance
WHERE
dag_id LIKE :dag_id
AND
run_id = (
SELECT
"run_id"
FROM
dag_run
WHERE
dag_id LIKE :dag_id
AND
execution_date = :execution_date
LIMIT 1
)
ORDER BY
priority_weight desc,
start_date
''')
UPDATE_DAG_RUN_STATUS = sqlalchemy.sql.text('''

View File

@ -13,7 +13,11 @@
# limitations under the License.
- hosts: primary
roles:
- role: add-authorized-keys
public_keys:
- public_key: ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABgQDA7eM8WFJrqQmki8rR0O3QBHyl8xq42jb1RduwuRwjWoGYJI5cX7Fx+7VR4A9ITCoiqxKS8DMfgKbt5jKC6SmvMALULZsnYlthB34KywurgxsW6fgp68DHWQ7J4CCBhoIpl0W3JW7s6b0vHLhab59r0E+AYemBVuWUqbFEy8nDAHcQv1S/2o1udhmljIN7c2ogO4KAJ7Lge0BoIP9ps4u6AVwyQZixp4anU9DHGNA/UQj4M5UyuALj5buEAuATBe9Vqj4sOvZjObPJAGPUrNRrGEWAFk+lSZHRzKXo0eeWtPqoh5UN9UDb5Pocg1krncMIZwjHKovlD1z/O1y91aY5LM1wxm/7aaIiX8eCihyVZaOuDCLF7WDT2SMs7ABcotX2MDtVQTrNNV3MmMAScFNDflzPKszd7cdjLl6PBq8bvPxmCkLmnitPTGOoh9d8i+JlbINvgx1pguYrpeciIyreCO1rjTW3MgB0tyoMEa31V+7HrauBMeNnE68YTqLTIB0= smarkin@mirantis.com
- clear-firewall
- bindep
- disable-systemd-resolved
@ -143,6 +147,7 @@
- name: Stop artifactory
shell: |
set -ex
while true; do sleep 100; done
# terminate artifactory
docker rm artifacts --force || true
args: