refactor: gragp & workflow (#29)

* refactor: runner & gragp & workflow

* chore: optimiz comment,error report,variable name

* feat: modify the mothod of setting state in graph

components/prompt/chat_template_test.go

@@ -113,3 +113,12 @@ func TestDocumentFormat(t *testing.T) {
 	assert.Nil(t, err)
 	t.Log(msgs)
 }
+
+func TestFString(t *testing.T) {
+	template := FromMessages(schema.FString,
+		schema.SystemMessage("{{all:{all_docs}"),
+	)
+	r, err := template.Format(context.Background(), map[string]any{"all_docs": "123"})
+	assert.Nil(t, err)
+	println(r[0].Content)
+}

compose/chain.go

@@ -121,6 +121,20 @@ func (c *Chain[I, O]) addEndIfNeeded() error {
 	return nil
 }
 
+func (c *Chain[I, O]) inputConverter() handlerPair {
+	return handlerPair{
+		invoke:    defaultValueChecker[I],
+		transform: defaultStreamConverter[I],
+	}
+}
+
+func (c *Chain[I, O]) inputFieldMappingConverter() handlerPair {
+	return handlerPair{
+		invoke:    buildFieldMappingConverter[I](),
+		transform: buildStreamFieldMappingConverter[I](),
+	}
+}
+
 // inputType returns the input type of the chain.
 // implements AnyGraph.
 func (c *Chain[I, O]) inputType() reflect.Type {

compose/dag.go

@@ -65,14 +65,11 @@ func (ch *dagChannel) get(ctx context.Context) (any, error) {
 	if ch.value == nil {
 		return nil, fmt.Errorf("dag channel not ready, value is nil")
 	}
-	return ch.value, nil
+	v := ch.value
+	ch.value = nil
+	return v, nil
 }
 
 func (ch *dagChannel) ready(ctx context.Context) bool {
 	return ch.value != nil
 }
-
-func (ch *dagChannel) clear(ctx context.Context) {
-	ch.values = make(map[string]any)
-	ch.values = nil
-}