Wats0ns

"apiVersion": |-
  argoproj.io/v1alpha1
"kind": |-
  Workflow
"metadata":
  "annotations":
    "pipelines.kubeflow.org/pipeline_spec": |-
      {"description": "A pipeline with two sequential steps.", "inputs": [{"default": "gs://kubeflow-ryanbouamara/kc_house_data.csv", "name": "url", "optional": true}, {"default": "/mnt/trained_model", "name": "trained_path", "optional": true}, {"default": "/mnt/dataset.csv", "name": "data_path", "optional": true}], "name": "Sequential pipeline"}
  "generateName": |-
    sequential-pipeline-

Wats0ns

#!/usr/bin/python3
import sys, socket
from multiprocessing.dummy import Pool as ThreadPool
import multiprocessing
import time

def starter(sockets):
    for sock in sockets:
        print("Broadcasting")
        sock.send("Broadcast tutut\n".encode())

Wats0ns

var crypto = require('crypto');

var hash_sha1 = function(password, salt){
  password = salt + password;
  var hash = crypto.createHash('sha1');
  hash.update(password);
  var value = hash.digest('hex');
  return value;
};