Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
2 changes: 1 addition & 1 deletion .claude/rules/prefect-pipeline-conventions.md
Original file line number Diff line number Diff line change
Expand Up @@ -305,7 +305,7 @@ my_flow.deploy_schedules = [
]
my_flow.job_variables = {
"memory": "8Gi",
"memory_limit": "8Gi", # <- the one the pod actually gets
"memory_limit": "8Gi", # <- the one the pod actually gets
"memory_request": "2Gi",
} # optional; size to the clean step's peak RAM
```
Expand Down
6 changes: 3 additions & 3 deletions .pre-commit-config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -18,11 +18,11 @@ repos:
args: [--fix=lf] # Ensures all line endings are LF
- repo: https://github.com/astral-sh/uv-pre-commit
# uv version.
rev: 0.11.32
rev: 0.12.17
hooks:
- id: uv-lock
- repo: https://github.com/astral-sh/ruff-pre-commit
rev: v0.16.0
rev: v0.16.8
hooks:
- id: ruff-check
args: [--fix]
Expand All @@ -39,7 +39,7 @@ repos:
- --exclude
- target/**/*
- repo: https://github.com/tconbeer/sqlfmt
rev: v0.27.0
rev: v0.27.0 # Keep sync with pyproject.toml
hooks:
- id: sqlfmt
language_version: python
Expand Down
14 changes: 10 additions & 4 deletions pipelines/datasets/br_me_comex_stat/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -138,10 +138,12 @@ O flow passou para o modelo de reconciliação de cobertura
`br_me_caged`:

```python
register_source_coverage_task(...) # grava o Poll e avança RawSource.Update
check_source_is_ahead_of_table_task(...) # gate: RawSource.Update > Table.Update
register_source_coverage_task(...) # grava o Poll e avança RawSource.Update
check_source_is_ahead_of_table_task(
...
) # gate: RawSource.Update > Table.Update
...
sync_table_coverage_task(...) # cobertura + RAPs + Table.Update como cobertura
sync_table_coverage_task(...) # cobertura + RAPs + Table.Update como cobertura
```

Agora os dois lados da comparação são data de cobertura. O `commit_source_update_task`
Expand Down Expand Up @@ -235,8 +237,12 @@ funciona. Para checar a descoberta localmente, importe com um shim:

```python
import enum

if not hasattr(enum, "StrEnum"):
class StrEnum(str, enum.Enum): pass

class StrEnum(str, enum.Enum):
pass

enum.StrEnum = StrEnum
```

Expand Down
42 changes: 21 additions & 21 deletions uv.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading