theycallmeloki

{
  "job": {
    "id": "f5bbb212ac3445c18febf33567edef31"
  },
  "transform": {
    "image": "laneone/ffmpeg-simpleconvert:latest",
    "cmd": [
      "python3",
      "/converter.py"
    ],

theycallmeloki

// the utility function to query pachyderm job completion data

const runPachctlCommand = (args: string[], callback: Function) => {
    console.log('Running 🐘🐘🐘 Pachctl 🐘🐘🐘');
  
      args.push('--raw');
      args.push('|');
      args.push('jq');
      // might need to make this next line `-sr` depending on
      // whether you want to slurp or not

theycallmeloki

import os
import sys
import re
import cv2

pfs_source_renderer = f"/pfs/{sys.argv[1]}"

def getXList(tiles):
    mergeFrame = {}

theycallmeloki

{
  "pipeline": {
    "name": "merger"
  },
  "input": {
    "pfs": {
      "glob": "/*/",
      "repo": "renderer"
    }
  },

theycallmeloki

import bpy
import sys
import json

job_id = sys.argv[10]
tile_id = sys.argv[11]
pfs_source_blends = sys.argv[12]
pfs_source_splitter = sys.argv[13]

f = json.loads(open(f'{pfs_source_splitter}/{job_id}/{tile_id}').read())

theycallmeloki

def render_blend(blend_source, job_source):
    print(job_source)
    tile_id = job_source.split("/")[4]

    f = json.loads(open(job_source).read())
    job_id = f["jobId"]
    frame = f["frame"]
    start_x = f["startX"]
    start_y = f["startY"]

theycallmeloki

import bpy
import os
import json
import sys

blendfile = sys.argv[6].rstrip(".blend")
pfs_source = sys.argv[7]
presplit = f'{pfs_source}/{blendfile}'

blend_params = {

theycallmeloki

import bpy
import sys
import json

job_id = sys.argv[10]
frame_id = sys.argv[11]
pfs_source_blends = sys.argv[12]
pfs_source_splitter = sys.argv[13]

f = json.loads(open(f'{pfs_source_splitter}/{job_id}/{frame_id}').read())

theycallmeloki

import os
import sys
import json
import subprocess
import re

pfs_source_blends = f"/pfs/{sys.argv[1]}"
pfs_source_splitter = ""
try:
    pfs_source_splitter = f"/pfs/{sys.argv[2]}"

theycallmeloki

{
  "pipeline": {
    "name": "renderer"
  },
  "input": {
    "cross": [
      {
        "pfs": {
          "glob": "/*",
          "repo": "blends"