1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
"""Tests JJ01 in a parallel environment.
This rule has had issues in the past with raising exceptions
in parallel environments because it tries to access the
templater.
"""
import pickle
from sqlfluff.core import FluffConfig, Linter
def test_lint_jj01_pickled_config():
"""Tests the error catching behavior of _lint_path_parallel_wrapper().
Test on MultiThread runner because otherwise we have pickling issues.
"""
fname = "test/fixtures/linter/jinja_spacing.sql"
fresh_cfg = FluffConfig(overrides={"dialect": "ansi", "rules": "JJ01"})
# Parse the file with the fresh config.
linter = Linter(config=fresh_cfg)
parsed = next(linter.parse_path(fname))
rule_pack = linter.get_rulepack(config=fresh_cfg)
rule = rule_pack.rules[0]
# Check we got the right rule.
assert rule.code == "JJ01"
# Pickle the config and rehydrate to simulate threaded operation
pickled = pickle.dumps(fresh_cfg)
unpickled_cfg = pickle.loads(pickled)
# Crawl with the pickled config. Check we don't get an error.
linting_errors, _, fixes, _ = rule.crawl(
parsed.tree,
dialect=unpickled_cfg.get("dialect_obj"),
fix=True,
templated_file=parsed.parsed_variants[0].templated_file,
ignore_mask=None,
fname=fname,
config=unpickled_cfg, # <- NOTE: This is the important part.
)
# Check we successfully got the right results.
assert len(linting_errors) == 1
assert linting_errors[0].check_tuple() == ("JJ01", 3, 15)
|
