Pipeline ID: budget/national/changes/explanations/all
flow
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/datapackage_pipelines/specs/../lib/flow.py", line 13, in <module>
flow = flow_module.flow(parameters, datapackage, resources, ctx.stats)
File "/datapackage_pipelines_budgetkey/pipelines/budget/national/changes/original/committee-zipfile.py", line 14, in flow
archive_ = gcl.download(WEIRD_ZIP_FILE, outfile=f'p{YEAR}.zip')
File "/datapackage_pipelines_budgetkey/common/google_chrome.py", line 219, in download
assert False, 'Failed to download file, %r' % downloads
AssertionError: Failed to download file, ['']
DEBUG :[chan 14] Max packet in: 32768 bytes
DEBUG :[chan 14] Max packet out: 32768 bytes
DEBUG :Secsh channel 14 opened.
DEBUG :[chan 14] Sesch channel 14 request ok
DEBUG :[chan 14] EOF received (14)
DEBUG :EOF in transport thread
DEBUG :[chan 14] EOF sent (14)
DEBUG :Dropping user packet because connection is dead.
Pipeline ID: budget/national/changes/original/committee-zipfile
Pipeline ID: budget/national/changes/original/current-year-fixes
Pipeline ID: budget/national/changes/original/national-budget-changes
Pipeline ID: budget/national/changes/processed/national-budget-changes-aggregated
extract-change-groups
Traceback (most recent call last):
File "/datapackage_pipelines_budgetkey/pipelines/budget/national/changes/processed/extract-change-groups.py", line 290, in <module>
main()
File "/datapackage_pipelines_budgetkey/pipelines/budget/national/changes/processed/extract-change-groups.py", line 287, in main
spew(update_datapackage(datapackage), process_resources(res_iter))
File "/usr/local/lib/python3.9/site-packages/datapackage_pipelines/wrapper/wrapper.py", line 75, in spew
for rec in res:
File "/datapackage_pipelines_budgetkey/pipelines/budget/national/changes/processed/extract-change-groups.py", line 269, in process_resource
for transaction in get_transactions(get_changes(rows)):
File "/datapackage_pipelines_budgetkey/pipelines/budget/national/changes/processed/extract-change-groups.py", line 230, in assign_transactions
changes = changes_by_trcode[trcode]
KeyError: '2011/83-068'
Pipeline ID: budget/national/changes/processed/transactions
We get the data the Ministry of Finance publishes in data.gov.il every year. It comes in XLS format, with one row per TAKANA and phase (original, approved, executed). In this pipeline we create from each triplet a single row that has all the data.
Pipeline ID: budget/national/original/national-budgets
This pipeline joins the different phases of the budget (allocated, revised and executed). In the original file there's a separate row for each of the phases. We like it better as a single row with all phase info. Another thing this pipeline does is to rename the column titles - to more friendly English names. Also, it create rows for all hierarchies - where upper hierarchies (2, 4 & 6 digits) are plain aggregations of the 8-digit items they contain.
Pipeline ID: budget/national/processed/aggregated-yearly
Pipeline ID: budget/national/processed/category-explanations
This pipeline joins budget items that span across years.
Pipeline ID: budget/national/processed/connected-items-explained
This pipeline joins budget items that span across years.
Pipeline ID: budget/national/processed/connected-national-budgets
Pipeline ID: budget/national/processed/just-the-total
Pipeline ID: budget/national/processed/roof-names
This pipeline joins the budget data to itself so that each item has a list of its immediate children.
Pipeline ID: budget/national/processed/with-extras
flow
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/datapackage_pipelines/specs/../lib/flow.py", line 13, in <module>
flow = flow_module.flow(parameters, datapackage, resources, ctx.stats)
File "/datapackage_pipelines_budgetkey/pipelines/budget/national/changes/original/committee-zipfile.py", line 14, in flow
archive_ = gcl.download(WEIRD_ZIP_FILE, outfile=f'p{YEAR}.zip')
File "/datapackage_pipelines_budgetkey/common/google_chrome.py", line 219, in download
assert False, 'Failed to download file, %r' % downloads
AssertionError: Failed to download file, ['']
DEBUG :[chan 14] Max packet in: 32768 bytes
DEBUG :[chan 14] Max packet out: 32768 bytes
DEBUG :Secsh channel 14 opened.
DEBUG :[chan 14] Sesch channel 14 request ok
DEBUG :[chan 14] EOF received (14)
DEBUG :EOF in transport thread
DEBUG :[chan 14] EOF sent (14)
DEBUG :Dropping user packet because connection is dead.
Pipeline ID: budget/national/changes/original/committee-zipfile
extract-change-groups
Traceback (most recent call last):
File "/datapackage_pipelines_budgetkey/pipelines/budget/national/changes/processed/extract-change-groups.py", line 290, in <module>
main()
File "/datapackage_pipelines_budgetkey/pipelines/budget/national/changes/processed/extract-change-groups.py", line 287, in main
spew(update_datapackage(datapackage), process_resources(res_iter))
File "/usr/local/lib/python3.9/site-packages/datapackage_pipelines/wrapper/wrapper.py", line 75, in spew
for rec in res:
File "/datapackage_pipelines_budgetkey/pipelines/budget/national/changes/processed/extract-change-groups.py", line 269, in process_resource
for transaction in get_transactions(get_changes(rows)):
File "/datapackage_pipelines_budgetkey/pipelines/budget/national/changes/processed/extract-change-groups.py", line 230, in assign_transactions
changes = changes_by_trcode[trcode]
KeyError: '2011/83-068'
Pipeline ID: budget/national/changes/processed/transactions
Pipeline ID: budget/national/changes/explanations/all
Pipeline ID: budget/national/changes/original/current-year-fixes
Pipeline ID: budget/national/changes/original/national-budget-changes
Pipeline ID: budget/national/changes/processed/national-budget-changes-aggregated
We get the data the Ministry of Finance publishes in data.gov.il every year. It comes in XLS format, with one row per TAKANA and phase (original, approved, executed). In this pipeline we create from each triplet a single row that has all the data.
Pipeline ID: budget/national/original/national-budgets
This pipeline joins the different phases of the budget (allocated, revised and executed). In the original file there's a separate row for each of the phases. We like it better as a single row with all phase info. Another thing this pipeline does is to rename the column titles - to more friendly English names. Also, it create rows for all hierarchies - where upper hierarchies (2, 4 & 6 digits) are plain aggregations of the 8-digit items they contain.
Pipeline ID: budget/national/processed/aggregated-yearly
Pipeline ID: budget/national/processed/category-explanations
This pipeline joins budget items that span across years.
Pipeline ID: budget/national/processed/connected-items-explained
This pipeline joins budget items that span across years.
Pipeline ID: budget/national/processed/connected-national-budgets
Pipeline ID: budget/national/processed/just-the-total
Pipeline ID: budget/national/processed/roof-names
This pipeline joins the budget data to itself so that each item has a list of its immediate children.
Pipeline ID: budget/national/processed/with-extras