Job Spec

job/README.md

@@ -0,0 +1,31 @@
+# IPVM Job Spec
+
+## Editors
+
+* [Brooklyn Zelenka](https://github.com/expede), [Fission](https://fission.codes)
+
+## Authors
+
+## Language
+
+The key words "MUST", "MUST NOT", "REQUIRED", "SHALL", "SHALL NOT", "SHOULD", "SHOULD NOT", "RECOMMENDED", "MAY", and "OPTIONAL" in this document are to be interpreted as described in [RFC2119](https://datatracker.ietf.org/doc/html/rfc2119).
+
+# 0 Abstract
+
+
+# 1 Motivation
+
+
+
+# 2 IPLD
+
+
+# 3 Acknowledgments
+
+
+# 4 Prior Art
+
+* [Docker Job Controller](https://kubernetes.io/docs/concepts/workloads/controllers/job/)
+* BucketVM (UCAN Invocation)
+* [WarpForge "Formula" v1](https://github.com/warpfork/warpforge/blob/master/examples/110-formula-usage/example-formula-exec.md)
+* [Bacalhau Job Spec](https://github.com/filecoin-project/bacalhau/blob/8568239299b5881bc90e3d6be2c9aa06c0cb3936/pkg/model/job.go#L192)

job/job.dot

@@ -0,0 +1,39 @@
+digraph G {
+    Pipeline -> {Job, JobL, JobR, JobE}
+
+    //
+
+    Job [shape = box]
+    Job -> {Invocation, Config, Version, requestorDid}
+
+    Invocation [shape = box]
+    Invocation -> Wasm [label = "exec"]
+    Invocation -> {a, b, c} [label = "arg"]
+
+    //
+
+    JobL [shape = box]
+    JobL -> {InvocationL, ConfigL, VersionL, requestorDidL}
+
+    InvocationL [shape = box]
+    InvocationL -> WasmL [label = "exec"]
+    InvocationL -> {d, e, f} [label = "arg"]
+
+    //
+
+    JobR [shape = box]
+    JobR -> {InvocationR, ConfigR, VersionR, requestorDidR}
+
+    InvocationR [shape = box]
+    InvocationR -> WasmR [label = "exec"]
+    InvocationR -> {g, h, i} [label = "arg"]
+
+    //
+
+    JobE [shape = box]
+    JobE -> {InvocationE, ConfigE, VersionE, requestorDidE}
+
+    InvocationE [shape = box]
+    InvocationE -> WasmR [label = "exec"]
+    InvocationE -> {j, k, l} [label = "arg"]
+}

job/job.json

@@ -0,0 +1,80 @@
+{
+    "type": "ipvm/job",
+    "version": "0.0.1",
+    "requestor": "did:key:zAlice",
+    "nonce": "ABCDEF",
+    "config": {
+        "label": "fission/run_the_reports",
+        "start": "asap",
+        "timeoutAt": 1667878395,
+        "maxGas": 4096,
+        "authz": ["QmUcan1", "QmUcan2"], // TODO move to post-negotiated?
+        "visibility": "public",
+        "verification": {
+            "method": "ipvm/optimistic-zk",
+            "min": 1,
+            "replication": 2,
+            "referee": "ipns://abcdefghi"
+        }
+    },
+    "run": {
+        "wasm": "bafyWasm",
+        "args": [
+            { "w": "Qm123456" },
+            { "x": "Qmabcdef" },
+            { "y": { "with": "dnslink://example.com", "run": "dnslink/resolve" } }
+            { "z": "QmFooBar" },
+        ],
+        "affinities": [], // TODO lives here, or in
+    },
+    "before": {
+        "database": {
+            "with": "dnslink://example.com",
+            "run": "dnslink/resolve"
+        }
+    },
+    "then": {
+        "effects": {
+            "bell": {
+                "run": "system/bell",
+                "on": "always"
+            }
+        },
+        "jobs": {
+            "left": {
+                "run": {
+                    "wasm": "bafyWasmLeft",
+                    "args": ["bafySomeArg"]
+                },
+                "then": {
+                    "jobs": {
+                        "subleft": {
+                            "run": {
+                                "wasm": "bafyWasmSubLeft",
+                                "args":
+                            }
+                        }
+                    }
+                }
+            },
+            "right": {
+                "run": "b"
+            },
+            "end": {
+                "run": {
+                    "wasm": "bafyWasmEnd",
+                    "input": {
+                        "foo": "jobs/left/subleft/"
+                }
+            }
+        }
+    },
+    "signature": "abcdef"
+}
+
+{
+    "type": "ipvm/deal",
+    "version": "0.0.1",
+    "accepter": "",
+    "job": "Qmabcdef"
+}

job/job.var1.json

@@ -0,0 +1,85 @@
+{
+    "type": "ipvm/job",
+    "version": "0.0.1",
+    "requestor": "did:key:zAlice",
+    "nonce": "ABCDEF",
+    "config": {
+        "label": "fission/run_the_reports",
+        "start": "asap",
+        "timeoutAt": 1667878395,
+        "maxGas": 4096,
+        "authz": ["QmUcan1", "QmUcan2"], // TODO move to post-negotiated?
+        "visibility": "public",
+        "verification": {
+            "method": "ipvm/optimistic-zk",
+            "min": 1,
+            "replication": 2,
+            "referee": "ipns://abcdefghi"
+        }
+    },
+    "jobs": {
+        "database": {
+            "run": {
+                "effect": {
+                    "with": "dnslink://example.com",
+                    "do": "dnslink/resolve",
+                    "timeout": "30s"
+                }
+            }
+        },
+        "start": {
+            "run": {
+                "wasm": "bafyWasm",
+                "input": [
+                    { "w": "Qm123456" },
+                    { "x": "Qmabcdef" },
+                    { "y": { "from": "database", "out": 0 } } // "Let the dataflow through you"
+                    { "z": "QmFooBar" },
+                ],
+                "affinities": [], // TODO lives here, or in
+            },
+            "after": {
+                "effects": {
+                    "bell": {
+                        "run": "system/bell",
+                        "when": "always"
+                    }
+                }
+            }
+        },
+        "left": {
+            "run": {
+                "wasm": "bafyWasmLeft",
+                "input": ["bafySomeArg"]
+            }
+        },
+        "subleft": {
+            "run": {
+                "wasm": "bafyWasmSubLeft",
+                "input": [101, {"from": "left"}, 42]
+            }
+        },
+        "right": {
+            "run": {
+                "wasm": "bafyWasmRight",
+                "input": [{"from": "start", "output": 4}, {"from": "database"}]
+            }
+        },
+        "end": {
+            "run": {
+                "wasm": "bafyWasmEnd",
+                "input": {
+                    "foo": "jobs/left/subleft/"
+                }
+            }
+        }
+    }
+    "signature": "abcdef"
+}
+
+{
+    "type": "ipvm/deal",
+    "version": "0.0.1",
+    "accepter": "",
+    "job": "Qmabcdef"
+}