Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-13035 [Playground] Streaming output
  3. BEAM-13156

[Playground] Implement streaming output for the run code logs

Details

    Description

      Implement streaming output for the run code logs:

      • set output variable (runOutput) for runCmd object to keep all logs from the run code step.
      • using additional goroutine to read from runOutput variable and add this output to cache (pipelineId:RunOutput:output) until runCmd runs code.
      • update GetRunOutput method to return existing logs from the run step. Also need to keep numbers of already returning lines to prevent duplicates.

      Attachments

        Issue Links

          Activity

            People

              Aydar Zaynutdinov Aydar Zaynutdinov
              Aydar Zaynutdinov Aydar Zaynutdinov
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 40m
                  40m