I'm currently working with SageMaker Pipelines and have a question about inter-step communication. In systems like Apache Airflow, there's a concept of XCom, which allows tasks to exchange small data artifacts or messages. I'm wondering if there's an equivalent feature in SageMaker Pipelines that would allow us to pass variables or small data artifacts directly between steps, without writing to and reading from an S3 bucket? Any help would be greatly appreciated.
AWS SageMaker pipeline xcom alternative
77 Views Asked by Shlomi Schwartz At
1
There are 1 best solutions below
Related Questions in AMAZON-WEB-SERVICES
- "Access Denied" - User's Permissions to S3 Bucket
- Cohort analysis with Amazon Redshift / PostgreSQL
- Using Amazon KMS service on Heroku
- can't ssh in after cloning an EC2 instance on Amazon AWS
- Using HDFS with Apache Spark on Amazon EC2
- How can I access Mule ESB Community edition via browser?
- AWS EC2: Migrating from Windows to Linux Server
- AWS ELB Load Balancer: is it possible to set multiple session cookies?
- AWS Flow Framework: Can we run activity worker and activity task on different EC2 instances
- Unable to access files from public s3 bucket with boto
- Cloudfront stream only part of the video
- s3cmd not working as cron-task when echos/dates are added
- How to deploy django 1.8 on Elastic Beanstalk using Docker
- InstanceProfile is required for creating cluster - create python function to install module
- How to fix WordPress HTTPS issues when behind an Amazon Load Balancer?
Related Questions in PIPELINE
- concat a lot of files to stdout
- How to write data to stdin of the first process in a Python shell pipeline?
- How do I define functions within a CmdletBinding() script?
- Powershell: "break" seems to end whole program, not just a loop?
- Passing properties to a function pipeline output error
- Reading POST data from Google App Engine pipeline callback
- Jenkins CI pipeline radiator
- elegant increment operator as pipeline
- Get conditional branch slot from MIPS cross compiler
- What is the equivalent of BlobstoreLineInputReader for targeting Google Cloud Storage?
- Comparative view in Paraview with identical Pipeline
- In sklearn, does a fitted pipeline reapply every transform?
- awk combine 2 commands for csv file formatting
- Pipeline and branch instructions
- Java Stage-based Processing Implementation
Related Questions in AMAZON-SAGEMAKER
- Getting an anomaly score for every datapoint in SageMaker?
- Load Amazon Sagemaker NTM model locally for inference
- Train autoencoder in script mode on AWS sagemaker
- Update a Sagemaker Endpoint when changing the docker image
- Custom package installation from S3 in sagemaker
- How best to install dependencies in a Sagemaker PySpark cluster
- Load Python Pickle File from S3 Bucket to Sagemaker Notebook
- Load Snowflake data into Pandas dataframe using AWS Sagemaker
- AWS Sagemaker + AWS Lambda
- Pyathena is super slow compared to querying from Athena
- How can I deploy a re-trained Sagemaker model to an endpoint?
- ‘precision_at_target_recall’, ‘recall_at_target_precision’ on hyper parameters on AWS SageMaker , how does it train with that constraint?
- Why is Crowd HTML breaking this image?
- OCI runtime create failed: container_linux.go:349: starting container process caused on sagemaker
- How to upload packages to an instance in a Processing step in Sagemaker?
Related Questions in AIRFLOW-XCOM
- Cannot access task instance to get xcom
- How to branch tasks in Airflow DAG based on SqlSensor success or skip status?
- XCOM - Win 2019 compatibility using old version of XCOM
- Airflow task instance xcom is empty in next task
- Airflow XCOM Pull in Taskgroup
- Airflow DAG: using returned values from previous task to create following tasks dynamically
- Airflow custom plugin: Value is not returned in XCOM even though I am able to view the value in log
- Use airflow for 2 task and i have a problem for run
- Airflow failed to get task instance
- Airflow XCOMs communication from BashOperator to PythonOperator
- Apache airflow xcom for variable task id
- Airflow ti.xcom_pull() return None
- How to add rows to a table using xcom_pull in PostgresOperator AIRFLOW
- Using xcom pushed value as parameter in BigQueryToGCSOperator
- json.decoder.JSONDecodeError when getting string from XCOM
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
With different steps you can take the output of the previous step and pass it in as an input for the next step. For example if you have a training step that you have defined like the following:
You can grab the model artifacts generated by this training job with the following code.