mirror of
https://github.com/ansible/awx.git
synced 2026-06-26 00:48:02 -02:30
Compare commits
4 Commits
forward-po
...
devel
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8ab5deb54a | ||
|
|
843f23f4cb | ||
|
|
6d665dda33 | ||
|
|
17dc7f898a |
@@ -68,7 +68,7 @@ class RecordedQueryLog(object):
|
|||||||
progname = match
|
progname = match
|
||||||
break
|
break
|
||||||
else:
|
else:
|
||||||
progname = os.path.basename(sys.argv[0])
|
progname = 'unknown'
|
||||||
filepath = os.path.join(self.dest, '{}.sqlite'.format(progname))
|
filepath = os.path.join(self.dest, '{}.sqlite'.format(progname))
|
||||||
version = _get_version('awx')
|
version = _get_version('awx')
|
||||||
log = sqlite3.connect(filepath, timeout=3)
|
log = sqlite3.connect(filepath, timeout=3)
|
||||||
|
|||||||
@@ -20,6 +20,9 @@ from dispatcherd.factories import get_control_from_settings
|
|||||||
# Django
|
# Django
|
||||||
from django.conf import settings
|
from django.conf import settings
|
||||||
from django.db import models, connection, transaction
|
from django.db import models, connection, transaction
|
||||||
|
|
||||||
|
# psycopg
|
||||||
|
from psycopg import sql
|
||||||
from django.db.models.constraints import UniqueConstraint
|
from django.db.models.constraints import UniqueConstraint
|
||||||
from django.core.exceptions import NON_FIELD_ERRORS
|
from django.core.exceptions import NON_FIELD_ERRORS
|
||||||
from django.utils.translation import gettext_lazy as _
|
from django.utils.translation import gettext_lazy as _
|
||||||
@@ -1179,17 +1182,23 @@ class UnifiedJob(
|
|||||||
raise StdoutMaxBytesExceeded(total, max_supported)
|
raise StdoutMaxBytesExceeded(total, max_supported)
|
||||||
|
|
||||||
tbl = self._meta.db_table + 'event'
|
tbl = self._meta.db_table + 'event'
|
||||||
created_by_cond = ''
|
where_parts = [
|
||||||
|
sql.SQL('{} = {}').format(sql.Identifier(self.event_parent_key), sql.Literal(self.id)),
|
||||||
|
sql.SQL("stdout != ''"),
|
||||||
|
]
|
||||||
if self.has_unpartitioned_events:
|
if self.has_unpartitioned_events:
|
||||||
tbl = f'_unpartitioned_{tbl}'
|
tbl = '_unpartitioned_' + tbl
|
||||||
else:
|
else:
|
||||||
created_by_cond = f"job_created='{self.created.isoformat()}' AND "
|
where_parts.insert(0, sql.SQL('job_created = {}').format(sql.Literal(self.created)))
|
||||||
|
|
||||||
sql = f"copy (select stdout from {tbl} where {created_by_cond}{self.event_parent_key}={self.id} and stdout != '' order by start_line) to stdout" # nosql
|
copy_sql = sql.SQL('COPY (SELECT stdout FROM {} WHERE {} ORDER BY start_line) TO STDOUT').format(
|
||||||
|
sql.Identifier(tbl),
|
||||||
|
sql.SQL(' AND ').join(where_parts),
|
||||||
|
)
|
||||||
# psycopg3's copy writes bytes, but callers of this
|
# psycopg3's copy writes bytes, but callers of this
|
||||||
# function assume a str-based fd will be returned; decode
|
# function assume a str-based fd will be returned; decode
|
||||||
# .write() calls on the fly to maintain this interface
|
# .write() calls on the fly to maintain this interface
|
||||||
with cursor.copy(sql) as copy:
|
with cursor.copy(copy_sql) as copy:
|
||||||
while data := copy.read():
|
while data := copy.read():
|
||||||
fd.write(smart_str(bytes(data)))
|
fd.write(smart_str(bytes(data)))
|
||||||
|
|
||||||
|
|||||||
@@ -830,14 +830,13 @@ class MockCopy:
|
|||||||
events = []
|
events = []
|
||||||
index = -1
|
index = -1
|
||||||
|
|
||||||
def __init__(self, sql):
|
def __init__(self):
|
||||||
self.events = []
|
self.events = []
|
||||||
parts = sql.split(' ')
|
|
||||||
tablename = parts[parts.index('from') + 1]
|
|
||||||
for cls in (JobEvent, AdHocCommandEvent, ProjectUpdateEvent, InventoryUpdateEvent, SystemJobEvent):
|
for cls in (JobEvent, AdHocCommandEvent, ProjectUpdateEvent, InventoryUpdateEvent, SystemJobEvent):
|
||||||
if cls._meta.db_table == tablename:
|
events = list(cls.objects.order_by('start_line').values_list('stdout', flat=True))
|
||||||
for event in cls.objects.order_by('start_line').all():
|
if events:
|
||||||
self.events.append(event.stdout)
|
self.events = events
|
||||||
|
break
|
||||||
|
|
||||||
def read(self):
|
def read(self):
|
||||||
self.index = self.index + 1
|
self.index = self.index + 1
|
||||||
@@ -858,9 +857,8 @@ def sqlite_copy(request, mocker):
|
|||||||
# copy is postgres-specific, and SQLite doesn't support it; mock its
|
# copy is postgres-specific, and SQLite doesn't support it; mock its
|
||||||
# behavior to test that it writes a file that contains stdout from events
|
# behavior to test that it writes a file that contains stdout from events
|
||||||
|
|
||||||
def write_stdout(self, sql):
|
def write_stdout(self, sql, params=None):
|
||||||
mock_copy = MockCopy(sql)
|
return MockCopy()
|
||||||
return mock_copy
|
|
||||||
|
|
||||||
mocker.patch.object(SQLiteCursorWrapper, 'copy', write_stdout, create=True)
|
mocker.patch.object(SQLiteCursorWrapper, 'copy', write_stdout, create=True)
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
import collections
|
import collections
|
||||||
import os
|
import os
|
||||||
import sqlite3
|
import sqlite3
|
||||||
import sys
|
|
||||||
import unittest
|
import unittest
|
||||||
|
|
||||||
import pytest
|
import pytest
|
||||||
@@ -125,7 +124,7 @@ def test_sql_above_threshold(tmpdir):
|
|||||||
args, kw = _call
|
args, kw = _call
|
||||||
assert args == ('EXPLAIN VERBOSE {}'.format(QUERY['sql']),)
|
assert args == ('EXPLAIN VERBOSE {}'.format(QUERY['sql']),)
|
||||||
|
|
||||||
path = os.path.join(tmpdir, '{}.sqlite'.format(os.path.basename(sys.argv[0])))
|
path = os.path.join(tmpdir, 'unknown.sqlite')
|
||||||
assert os.path.exists(path)
|
assert os.path.exists(path)
|
||||||
|
|
||||||
# verify the results
|
# verify the results
|
||||||
|
|||||||
@@ -438,7 +438,7 @@ class ControllerAPIModule(ControllerModule):
|
|||||||
raise RuntimeError('Expected list from API at {0}, got: {1}'.format(endpoint, response))
|
raise RuntimeError('Expected list from API at {0}, got: {1}'.format(endpoint, response))
|
||||||
next_page = response['json']['next']
|
next_page = response['json']['next']
|
||||||
|
|
||||||
if response['json']['count'] > 10000:
|
if response['json'].get('count', 0) > 10000:
|
||||||
self.fail_json(msg='The number of items being queried for is higher than 10,000.')
|
self.fail_json(msg='The number of items being queried for is higher than 10,000.')
|
||||||
|
|
||||||
while next_page is not None:
|
while next_page is not None:
|
||||||
@@ -493,8 +493,11 @@ class ControllerAPIModule(ControllerModule):
|
|||||||
fail_msg += ', detail: {0}'.format(response['json']['detail'])
|
fail_msg += ', detail: {0}'.format(response['json']['detail'])
|
||||||
self.fail_json(msg=fail_msg)
|
self.fail_json(msg=fail_msg)
|
||||||
|
|
||||||
if 'count' not in response['json'] or 'results' not in response['json']:
|
if 'results' not in response['json']:
|
||||||
self.fail_json(msg="The endpoint did not provide count and results")
|
self.fail_json(msg="The endpoint did not provide a results list")
|
||||||
|
|
||||||
|
if 'count' not in response['json']:
|
||||||
|
response['json']['count'] = len(response['json']['results'])
|
||||||
|
|
||||||
if response['json']['count'] == 0:
|
if response['json']['count'] == 0:
|
||||||
if allow_none:
|
if allow_none:
|
||||||
|
|||||||
Reference in New Issue
Block a user