-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathrun_example_processor.jl
More file actions
33 lines (30 loc) · 890 Bytes
/
Copy pathrun_example_processor.jl
File metadata and controls
33 lines (30 loc) · 890 Bytes
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
using CopernicusData
using TOML
# Run through the triggering process
payload_file = "resources/payload.toml"
@time p = EOTriggering.run(payload_file)
# Run manually the first workflow
payload_file = "resources/payload.toml"
payload = TOML.parsefile(payload_file)
## Get ADFs
adfs = Dict{String, Any}()
for adf in payload["workflow"][1]["parameters"]["aux_files"]
id = pop!(adf,"id")
adfs[id] = adf
end
## Get input
inputs = Vector{Dict{String, Any}}()
for id in payload["workflow"][1]["inputs"]
for p in payload["I/O"]["inputs_products"]
if p["id"] == id
push!(inputs, p)
end
end
end
@debug adfs
@debug inputs
dt = open_datatree(inputs[1]["path"], name=inputs[1]["id"])
kwargs = Dict()
kwargs[:start_time] = "2019-12-27T12:41:00.000"
kwargs[:stop_time] = "2019-12-27T12:44:00.000"
res = ExampleProcessor.example_processor([dt],adfs;kwargs...)