More subflow fixes

This commit is contained in:
frikky
2023-04-13 15:37:22 +02:00
parent 274a942e88
commit 27457637c1
8 changed files with 83 additions and 71 deletions
+2 -2
View File
@@ -3805,7 +3805,7 @@ class AppBase:
# BASE URL (backend) # BASE URL (backend)
try: try:
app.url = requestdata["url"] app.url = requestdata["url"]
logger.info(f"BACKEND URL: {app.url}") logger.info(f"BACKEND URL (url): {app.url}")
except Exception as e: except Exception as e:
logger.info(f"[ERROR] Failed parsing url (backend): {e}") logger.info(f"[ERROR] Failed parsing url (backend): {e}")
extra_info += f"\n{e}" extra_info += f"\n{e}"
@@ -3813,7 +3813,7 @@ class AppBase:
# URL (worker) # URL (worker)
try: try:
app.base_url = requestdata["base_url"] app.base_url = requestdata["base_url"]
logger.info(f"WORKER URL: {app.base_url}") logger.info(f"WORKER URL (base url): {app.base_url}")
except Exception as e: except Exception as e:
logger.info(f"[ERROR] Failed parsing base url (worker): {e}") logger.info(f"[ERROR] Failed parsing base url (worker): {e}")
extra_info += f"\n{e}" extra_info += f"\n{e}"
+1 -1
View File
@@ -19,7 +19,7 @@ require (
github.com/gorilla/mux v1.8.0 github.com/gorilla/mux v1.8.0
github.com/h2non/filetype v1.1.3 github.com/h2non/filetype v1.1.3
github.com/satori/go.uuid v1.2.0 github.com/satori/go.uuid v1.2.0
github.com/shuffle/shuffle-shared v0.4.0 github.com/shuffle/shuffle-shared v0.4.1
golang.org/x/crypto v0.3.0 golang.org/x/crypto v0.3.0
google.golang.org/api v0.103.0 google.golang.org/api v0.103.0
google.golang.org/appengine v1.6.7 google.golang.org/appengine v1.6.7
+2 -2
View File
@@ -13,7 +13,7 @@ import (
//"crypto/tls" //"crypto/tls"
//"crypto/x509" //"crypto/x509"
"encoding/base64" //"encoding/base64"
"encoding/hex" "encoding/hex"
"encoding/json" "encoding/json"
"errors" "errors"
@@ -1269,7 +1269,7 @@ func checkAdminLogin(resp http.ResponseWriter, request *http.Request) {
// Should run calculations // Should run calculations
if len(org.SSOConfig.OpenIdAuthorization) > 0 { if len(org.SSOConfig.OpenIdAuthorization) > 0 {
baseSSOUrl = shuffle.GetOpenIdUrl(org) baseSSOUrl = shuffle.GetOpenIdUrl(request, *org)
break break
} }
+58 -58
View File
@@ -1,69 +1,69 @@
version: '3' version: '3'
services: services:
frontend: #frontend:
image: ghcr.io/shuffle/shuffle-frontend:latest # image: ghcr.io/shuffle/shuffle-frontend:latest
container_name: shuffle-frontend # container_name: shuffle-frontend
hostname: shuffle-frontend # hostname: shuffle-frontend
ports: # ports:
- "${FRONTEND_PORT}:80" # - "${FRONTEND_PORT}:80"
- "${FRONTEND_PORT_HTTPS}:443" # - "${FRONTEND_PORT_HTTPS}:443"
networks: # networks:
- shuffle # - shuffle
environment: # environment:
- BACKEND_HOSTNAME=${BACKEND_HOSTNAME} # - BACKEND_HOSTNAME=${BACKEND_HOSTNAME}
restart: unless-stopped # restart: unless-stopped
depends_on: # depends_on:
- backend # - backend
backend: #backend:
image: ghcr.io/shuffle/shuffle-backend:latest # image: ghcr.io/shuffle/shuffle-backend:latest
container_name: shuffle-backend # container_name: shuffle-backend
hostname: ${BACKEND_HOSTNAME} # hostname: ${BACKEND_HOSTNAME}
# Here for debugging: # # Here for debugging:
ports: # ports:
- "${BACKEND_PORT}:5001" # - "${BACKEND_PORT}:5001"
networks: # networks:
- shuffle # - shuffle
volumes: # volumes:
- /var/run/docker.sock:/var/run/docker.sock # - /var/run/docker.sock:/var/run/docker.sock
- ${SHUFFLE_APP_HOTLOAD_LOCATION}:/shuffle-apps:z # - ${SHUFFLE_APP_HOTLOAD_LOCATION}:/shuffle-apps:z
- ${SHUFFLE_FILE_LOCATION}:/shuffle-files:z # - ${SHUFFLE_FILE_LOCATION}:/shuffle-files:z
env_file: .env # env_file: .env
environment: # environment:
#- DOCKER_HOST=tcp://docker-socket-proxy:2375 # #- DOCKER_HOST=tcp://docker-socket-proxy:2375
- SHUFFLE_APP_HOTLOAD_FOLDER=/shuffle-apps # - SHUFFLE_APP_HOTLOAD_FOLDER=/shuffle-apps
- SHUFFLE_FILE_LOCATION=/shuffle-files # - SHUFFLE_FILE_LOCATION=/shuffle-files
restart: unless-stopped # restart: unless-stopped
orborus: #orborus:
image: ghcr.io/shuffle/shuffle-orborus:latest # image: ghcr.io/shuffle/shuffle-orborus:latest
container_name: shuffle-orborus # container_name: shuffle-orborus
hostname: shuffle-orborus # hostname: shuffle-orborus
networks: # networks:
- shuffle # - shuffle
volumes: # volumes:
- /var/run/docker.sock:/var/run/docker.sock # - /var/run/docker.sock:/var/run/docker.sock
environment: # environment:
#- DOCKER_HOST=tcp://docker-socket-proxy:2375 # #- DOCKER_HOST=tcp://docker-socket-proxy:2375
- SHUFFLE_WORKER_VERSION=latest # - SHUFFLE_WORKER_VERSION=latest
- ENVIRONMENT_NAME=${ENVIRONMENT_NAME} # - ENVIRONMENT_NAME=${ENVIRONMENT_NAME}
- BASE_URL=http://${OUTER_HOSTNAME}:5001 # - BASE_URL=http://${OUTER_HOSTNAME}:5001
- DOCKER_API_VERSION=1.40 # - DOCKER_API_VERSION=1.40
- SHUFFLE_BASE_IMAGE_NAME=${SHUFFLE_BASE_IMAGE_NAME} # - SHUFFLE_BASE_IMAGE_NAME=${SHUFFLE_BASE_IMAGE_NAME}
- SHUFFLE_BASE_IMAGE_REGISTRY=${SHUFFLE_BASE_IMAGE_REGISTRY} # - SHUFFLE_BASE_IMAGE_REGISTRY=${SHUFFLE_BASE_IMAGE_REGISTRY}
- SHUFFLE_BASE_IMAGE_TAG_SUFFIX=${SHUFFLE_BASE_IMAGE_TAG_SUFFIX} # - SHUFFLE_BASE_IMAGE_TAG_SUFFIX=${SHUFFLE_BASE_IMAGE_TAG_SUFFIX}
- HTTP_PROXY=${HTTP_PROXY} # - HTTP_PROXY=${HTTP_PROXY}
- HTTPS_PROXY=${HTTPS_PROXY} # - HTTPS_PROXY=${HTTPS_PROXY}
- SHUFFLE_PASS_WORKER_PROXY=${SHUFFLE_PASS_WORKER_PROXY} # - SHUFFLE_PASS_WORKER_PROXY=${SHUFFLE_PASS_WORKER_PROXY}
- SHUFFLE_PASS_APP_PROXY=${SHUFFLE_PASS_APP_PROXY} # - SHUFFLE_PASS_APP_PROXY=${SHUFFLE_PASS_APP_PROXY}
restart: unless-stopped # restart: unless-stopped
security_opt: # security_opt:
- seccomp:unconfined # - seccomp:unconfined
opensearch: opensearch:
image: opensearchproject/opensearch:2.5.0 image: opensearchproject/opensearch:2.5.0
hostname: shuffle-opensearch hostname: shuffle-opensearch
container_name: shuffle-opensearch container_name: shuffle-opensearch
environment: environment:
- bootstrap.memory_lock=true - bootstrap.memory_lock=true
- "OPENSEARCH_JAVA_OPTS=-Xms2048m -Xmx2048m" # minimum and maximum Java heap size, recommend setting both to 50% of system RAM - "OPENSEARCH_JAVA_OPTS=-Xms1048m -Xmx1048m" # minimum and maximum Java heap size, recommend setting both to 50% of system RAM
- cluster.initial_master_nodes=shuffle-opensearch - cluster.initial_master_nodes=shuffle-opensearch
- cluster.routing.allocation.disk.threshold_enabled=false - cluster.routing.allocation.disk.threshold_enabled=false
- cluster.name=shuffle-cluster - cluster.name=shuffle-cluster
+13 -7
View File
@@ -1957,8 +1957,9 @@ const Admin = (props) => {
<DialogContent color="textSecondary"> <DialogContent color="textSecondary">
What does{" "} What does{" "}
<a <a
href="https://shuffler.io/docs/organizations#cloud_sync" href="/docs/organizations#cloud_sync"
target="_blank" target="_blank"
rel="noopener noreferrer"
style={{ textDecoration: "none", color: "#f85a3e" }} style={{ textDecoration: "none", color: "#f85a3e" }}
> >
cloud sync cloud sync
@@ -2049,7 +2050,8 @@ const Admin = (props) => {
organization.{" "} organization.{" "}
<a <a
target="_blank" target="_blank"
href="https://shuffler.io/docs/organizations#organization" rel="noopener noreferrer"
href="/docs/organizations#organization"
style={{ textDecoration: "none", color: "#f85a3e" }} style={{ textDecoration: "none", color: "#f85a3e" }}
> >
Learn more Learn more
@@ -2239,7 +2241,7 @@ const Admin = (props) => {
</Typography> </Typography>
What does{" "} What does{" "}
<a <a
href="https://shuffler.io/docs/organizations#cloud_sync" href="/docs/organizations#cloud_sync"
target="_blank" target="_blank"
rel="noopener noreferrer" rel="noopener noreferrer"
style={{ textDecoration: "none", color: "#f85a3e" }} style={{ textDecoration: "none", color: "#f85a3e" }}
@@ -2672,7 +2674,7 @@ const Admin = (props) => {
<a <a
target="_blank" target="_blank"
rel="noopener noreferrer" rel="noopener noreferrer"
href="https://shuffler.io/docs/organizations#user_management" href="/docs/organizations#user_management"
style={{ textDecoration: "none", color: "#f85a3e" }} style={{ textDecoration: "none", color: "#f85a3e" }}
> >
Learn more Learn more
@@ -3009,7 +3011,8 @@ const Admin = (props) => {
Schedules used in Workflows. Makes locating and control easier.{" "} Schedules used in Workflows. Makes locating and control easier.{" "}
<a <a
target="_blank" target="_blank"
href="https://shuffler.io/docs/organizations#schedules" rel="noopener noreferrer"
href="/docs/organizations#schedules"
style={{ textDecoration: "none", color: "#f85a3e" }} style={{ textDecoration: "none", color: "#f85a3e" }}
> >
Learn more Learn more
@@ -3074,6 +3077,7 @@ const Admin = (props) => {
style={{ textDecoration: "none", color: "#f85a3e" }} style={{ textDecoration: "none", color: "#f85a3e" }}
href={`/workflows/${schedule.workflow_id}`} href={`/workflows/${schedule.workflow_id}`}
target="_blank" target="_blank"
rel="noopener noreferrer"
> >
{schedule.workflow_id} {schedule.workflow_id}
</a> </a>
@@ -3214,7 +3218,8 @@ const Admin = (props) => {
&nbsp; &nbsp;
<a <a
target="_blank" target="_blank"
href="https://shuffler.io/docs/organizations#app_authentication" rel="noopener noreferrer"
href="/docs/organizations#app_authentication"
style={{ textDecoration: "none", color: "#f85a3e" }} style={{ textDecoration: "none", color: "#f85a3e" }}
> >
Learn more about authentication Learn more about authentication
@@ -3439,7 +3444,8 @@ const Admin = (props) => {
in.{" "} in.{" "}
<a <a
target="_blank" target="_blank"
href="https://shuffler.io/docs/organizations#environments" rel="noopener noreferrer"
href="/docs/organizations#environments"
style={{ textDecoration: "none", color: "#f85a3e" }} style={{ textDecoration: "none", color: "#f85a3e" }}
> >
Learn more Learn more
+1 -1
View File
@@ -14574,7 +14574,7 @@ const AngularWorkflow = (defaultprops) => {
{curapp === null ? null : ( {curapp === null ? null : (
<img <img
alt={selectedResult.app_name} alt={selectedResult.app_name}
src={curapp === undefined ? theme.palette.defaultImage : curapp.large_image} src={curapp === undefined ? theme.palette.defaultImage : curapp.app_name === "shuffle-subflow" ? triggers[4].large_image : curapp.app_name === "User Input" ? triggers[5].large_image : curapp.large_image}
style={{ style={{
marginRight: 20, marginRight: 20,
width: imgsize, width: imgsize,
+2
View File
@@ -204,6 +204,8 @@ github.com/shuffle/shuffle-shared v0.3.74 h1:i7M1Gug9j2Wa02WuSxKDbXoLvBWKW5Pxf/E
github.com/shuffle/shuffle-shared v0.3.74/go.mod h1:jQrYySmvp/0De5ftrAaY6xwwr7TMfqBmBxQ2AX9yrjQ= github.com/shuffle/shuffle-shared v0.3.74/go.mod h1:jQrYySmvp/0De5ftrAaY6xwwr7TMfqBmBxQ2AX9yrjQ=
github.com/shuffle/shuffle-shared v0.3.75 h1:ALXJSn13kcRbxfax1p/d1hvh1LL6Rx8iBhw2UJ5OuAQ= github.com/shuffle/shuffle-shared v0.3.75 h1:ALXJSn13kcRbxfax1p/d1hvh1LL6Rx8iBhw2UJ5OuAQ=
github.com/shuffle/shuffle-shared v0.3.75/go.mod h1:jQrYySmvp/0De5ftrAaY6xwwr7TMfqBmBxQ2AX9yrjQ= github.com/shuffle/shuffle-shared v0.3.75/go.mod h1:jQrYySmvp/0De5ftrAaY6xwwr7TMfqBmBxQ2AX9yrjQ=
github.com/shuffle/shuffle-shared v0.4.0 h1:ooM8v1tes6uivx+20vXZKyqvKCu0OU36cx9vI66H6dI=
github.com/shuffle/shuffle-shared v0.4.0/go.mod h1:jQrYySmvp/0De5ftrAaY6xwwr7TMfqBmBxQ2AX9yrjQ=
github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e h1:MRM5ITcdelLK2j1vwZ3Je0FKVCfqOLp5zO6trqMLYs0= github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e h1:MRM5ITcdelLK2j1vwZ3Je0FKVCfqOLp5zO6trqMLYs0=
github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e/go.mod h1:XV66xRDqSt+GTGFMVlhk3ULuV0y9ZmzeVGR4mloJI3M= github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e/go.mod h1:XV66xRDqSt+GTGFMVlhk3ULuV0y9ZmzeVGR4mloJI3M=
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+4
View File
@@ -459,6 +459,10 @@ func deployServiceWorkers(image string) {
serviceSpec.TaskTemplate.ContainerSpec.Env = append(serviceSpec.TaskTemplate.ContainerSpec.Env, fmt.Sprintf("BASE_URL=%s", os.Getenv("BASE_URL"))) serviceSpec.TaskTemplate.ContainerSpec.Env = append(serviceSpec.TaskTemplate.ContainerSpec.Env, fmt.Sprintf("BASE_URL=%s", os.Getenv("BASE_URL")))
} }
if len(os.Getenv("SHUFFLE_CLOUDRUN_URL")) > 0 {
serviceSpec.TaskTemplate.ContainerSpec.Env = append(serviceSpec.TaskTemplate.ContainerSpec.Env, fmt.Sprintf("SHUFFLE_CLOUDRUN_URL=%s", os.Getenv("SHUFFLE_CLOUDRUN_URL")))
}
if len(os.Getenv("DOCKER_HOST")) > 0 { if len(os.Getenv("DOCKER_HOST")) > 0 {
serviceSpec.TaskTemplate.ContainerSpec.Env = append(serviceSpec.TaskTemplate.ContainerSpec.Env, fmt.Sprintf("DOCKER_HOST=%s", os.Getenv("DOCKER_HOST"))) serviceSpec.TaskTemplate.ContainerSpec.Env = append(serviceSpec.TaskTemplate.ContainerSpec.Env, fmt.Sprintf("DOCKER_HOST=%s", os.Getenv("DOCKER_HOST")))
} else { } else {