Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Flowcharts #4631

Draft
wants to merge 51 commits into
base: main
Choose a base branch
from
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
51 commits
Select commit Hold shift + click to select a range
f379742
do internal links work?
maskarb Jul 15, 2023
f97b88c
do internal links work?
maskarb Jul 15, 2023
0b14dff
remove link
maskarb Jul 15, 2023
7f5c956
remove link
maskarb Jul 15, 2023
5875d4c
add the link back
maskarb Jul 15, 2023
92d2108
add different link
maskarb Jul 15, 2023
39b5858
lets try this
maskarb Jul 15, 2023
698f3f7
is this clickable?
maskarb Jul 15, 2023
462e371
just leave a comment
maskarb Jul 15, 2023
567b521
this might be overkill
maskarb Jul 15, 2023
0c17104
fix unleash flag for XL customers (#4577)
lcouzens Jul 14, 2023
e965cca
Remove deprecation for rbac setting (#4578)
myersCody Jul 14, 2023
40327e6
Update settings access control to fix admin conditioning. (#4585)
myersCody Jul 17, 2023
00f7c58
[COST-3956] others included in ordering by cost & limit (#4532)
myersCody Jul 17, 2023
ef7e3e8
Correct refresh XL queue name (#4581)
samdoran Jul 17, 2023
361c8d0
use `inclause` sqljinja filter in templates (#4573)
maskarb Jul 17, 2023
7450332
bump nise version to include subs columns in test data (#4583)
djnakabaale Jul 17, 2023
3f8107f
[COST-3984] Do not update summary tables if there are no AWS bills (#…
samdoran Jul 18, 2023
f72b343
Add settings to rbac python file. (#4586)
myersCody Jul 18, 2023
c01f14c
[COST-3984] - check Azure and GCP bills too (#4587)
maskarb Jul 19, 2023
af7d406
[COST-3990] Add write check to user_access endpoint (#4570)
myersCody Jul 19, 2023
5223e0c
[COST-3572] handle daily operator payloads (#4546)
maskarb Jul 19, 2023
671f557
[COST-3891/COST-3893] Add workers for SUBS data extraction and trans…
djnakabaale Jul 19, 2023
2150b44
[COST-4001] - handle OCI exception (#4588)
lcouzens Jul 20, 2023
07719a7
[COST-4026] Update Grafana dashboard for XL queue (#4579)
samdoran Jul 21, 2023
feaf037
[COST-4044] log schema name rather than customer id (#4591)
maskarb Jul 21, 2023
86a9101
[COST-3808] add external-id to sources integration (#4589)
maskarb Jul 21, 2023
8b45c86
Revert "[COST-3891/COST-3893] Add workers for SUBS data extraction a…
maskarb Jul 24, 2023
9a29f04
Just for Eva (#4592)
lcouzens Jul 24, 2023
80dfaf5
[COST-3585] Create new model to hold all tags (#4594)
samdoran Jul 24, 2023
36b9d44
Deprecate pr_check.sh script (#4596)
Victoremepunto Jul 25, 2023
e97e7fa
[COST-3891/COST-3893] Add workers for SUBS data extraction and trans…
djnakabaale Jul 26, 2023
7e646e5
[COST-3996] Unleash flag to disable tag enablement on settings. (#4598)
myersCody Jul 26, 2023
435abc1
[COST-3974] Switch data process to use new unified enabled tag table …
myersCody Jul 27, 2023
af0c1c9
bump oci, certifi, cryptography (#4601)
maskarb Jul 27, 2023
985436f
[COST-3890/3892] Data Extraction and Kafka Messaging for SUBS (#4556)
cgoodfred Jul 31, 2023
8632d85
[COST-3753] Add an enabled tag limit. (#4603)
myersCody Aug 2, 2023
a4ec53f
Pin kombu so dependabot can update dependencies without breaking ever…
maskarb Aug 2, 2023
52a2ab5
drop date override from OCP flow (#4606)
lcouzens Aug 3, 2023
b13ce78
[COST-3892] split Identity/TimeInterval into start and end to have aw…
cgoodfred Aug 3, 2023
bfccf33
[COST-3892] Make subs event type lowercase (#4610)
cgoodfred Aug 3, 2023
e68625f
[COST-4012] Don't check serviceinfo2 for Azure HCS filter (#4565)
cgoodfred Aug 4, 2023
342aa55
[COST-3991] daily-archive-idea (#4533)
lcouzens Aug 4, 2023
d80e372
Fix unleash check for subs (#4613)
cgoodfred Aug 4, 2023
22415df
chore(image): update and rebuild image (#4619)
github-actions[bot] Aug 9, 2023
f79429d
try to make the chart more visually understandable
maskarb Aug 9, 2023
23b045c
Merge branch 'main' into flowcharts
maskarb Aug 9, 2023
f7e3985
start on higher level flowchart
maskarb Aug 10, 2023
3d727b9
Merge branch 'main' into flowcharts
maskarb Aug 14, 2023
2c8437d
some updates
maskarb Aug 17, 2023
f3101b8
Merge branch 'main' into flowcharts
maskarb Aug 30, 2023
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
26 changes: 26 additions & 0 deletions docs/flowcharts/00-processing-overview.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
```mermaid

graph

A["Orchestrator.prepare()"] --> B[start-manifest-processing]
B --> C["ReportDownloader()"]
C --> D["get manifest list\n(download manifest, insert manifest record)"]
D --> |"iterate over manifests (only GCP has more than 1)"| E["ensure each file of manifest has status record (weirdly done)"]
E --> |iterate over each file of manifest| F["generate new `report_context` dict from manifest copy"]
F --> G[create list of tasks to download report file]
G --> H["trigger task to download files (pass in report context and account info)"]

H --> I[get_report_files]
I --> J[_get_report_files]
J --> K["ReportDownloader()"]
K --> L[download file]




```


H --> I[trigger summary tasks]
H --> J[trigger hcs tasks]
H --> K[trigger subs tasks]
25 changes: 25 additions & 0 deletions docs/flowcharts/01-check-report-updates.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
```mermaid

graph
A["check_report_updates (scheduled task)"] -->|"masu.celery.tasks.check_report_updates (default queue)"| B["Orchestrator(scheduled=True).prepare()"]
B --> C[for provider in pollable_providers]
C --> D{providers left?}
D -->|yes| E[provider-type]
E -->|AWS/Azure| F[O.prepare_monthly_report_sources]
F --> G["report_months = O.get_reports\n(there is some masu API specific logic in\nhere. But also, this returns\nmonths to iterate over...)"]
G --> H["for month in report_months\n(list of datetime.date)"]
H --> I{months left?}
I -->|yes| J[" `account['report_month'] = month`\nself.start_manifest_processing\n(see 02-start-manifest-processing.md)"]
J -->|Success| K[label accounts]
K -->|Success/Exception| I
J -->|Exception| I
I -->|no| D


E -->|GCP/OCI| L[O.prepare_continuous_report_sources]
L --> M[" `account['report_month'] = start_date`\n`DateAccessor().get_billing_month_start(f'{self.bill_date}01')` (a datetime.date)\nor\nDateHelper().today (a datetime.datetime)"]
M --> N["self.start_manifest_processing\n(see 02-start-manifest-processing.md)"]
N -->|Success/Exception| D

D -->|"no"| Z[Done]
```
Empty file.