wdl-analysis 0.24.0

Analysis of Workflow Description Language (WDL) documents.
Documentation 
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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

## This tests that accessing members produces appropriate errors/successes.
##
## The `task` variable is available in both pre-evaluation contexts
## (requirements/hints/runtime) and post-evaluation contexts (command/output),
## but with different fields available in each context.

version 1.3

task test_invalid_member {
  command <<<
    # All task fields available in command.
    echo "name: ~{task.name}"
    echo "id: ~{task.id}"
    echo "attempt: ~{task.attempt}"
    echo "cpu: ~{task.cpu}"
    echo "memory: ~{task.memory}"
    echo "container: ~{task.container}"
    echo "previous_cpu: ~{select_first([task.previous.cpu, 0])}"
    echo "previous_memory: ~{select_first([task.previous.memory, 0])}"
  >>>

  requirements {
    # Available in pre-evaluation.
    memory: if task.name == "test" then 1000000000 else 2000000000

    # Available in pre-evaluation.
    container: if task.id == "test-1" then "ubuntu:latest" else "debian:latest"

    # Available in pre-evaluation.
    cpu: task.attempt + 1

    # Available in pre-evaluation.
    disks: if defined(task.previous.disks) then [select_first([task.previous.disks, {}])["local-disk"] + " GiB"] else ["10 GiB"]

    # Not a valid member of `task.previous` (error).
    gpu: select_first([task.previous.not_a_member, []])

    # `task.cpu` not available in pre-evaluation (error).
    fpga: task.cpu > 2

    # `task.memory` not available in pre-evaluation (error).
    maxRetries: task.memory / 1000000000
  }

  output {
    # All task fields available in output.
    String task_name = task.name
    String task_id = task.id
    Int attempt = task.attempt
    Float cpu = task.cpu
    Int memory = task.memory
    String? container = task.container
    Int? previous_memory = task.previous.memory
    Float? previous_cpu = task.previous.cpu
    String? previous_container = task.previous.container
    Array[String]? previous_gpu = task.previous.gpu
    Array[String]? previous_fpga = task.previous.fpga
    Map[String, Int]? previous_disks = task.previous.disks
    Int? previous_max_retries = task.previous.max_retries
    Int return_code = task.return_code

    Int gpu_count = length(select_first([task.previous.gpu, []]))
    Int fpga_count = length(select_first([task.previous.fpga, []]))
    Int disk_count = length(keys(select_first([task.previous.disks, {}])))
  }
}