Update upstream

[acroca]

This PR brings upstream changes into the dapr fork.

• Merged microsoft@a49f1e0
• Removed azuremanaged files
• Relocated

  durabletask-python/tests/test_client.py

  Lines 93 to 147 in 4602067

  	@pytest.mark.parametrize("timeout", [None, 0, 5])
  	def test_wait_for_orchestration_start_timeout(timeout):
  	instance_id = "test-instance"
  	from durabletask.internal.orchestrator_service_pb2 import GetInstanceResponse, \
  	OrchestrationState, ORCHESTRATION_STATUS_RUNNING
  	response = GetInstanceResponse()
  	state = OrchestrationState()
  	state.instanceId = instance_id
  	state.orchestrationStatus = ORCHESTRATION_STATUS_RUNNING
  	response.orchestrationState.CopyFrom(state)
  	c = TaskHubGrpcClient()
  	c._stub = Mock()
  	c._stub.WaitForInstanceStart.return_value = response
  	grpc_timeout = None if timeout is None else timeout
  	c.wait_for_orchestration_start(instance_id, timeout=grpc_timeout)
  	# Verify WaitForInstanceStart was called with timeout=None
  	c._stub.WaitForInstanceStart.assert_called_once()
  	_, kwargs = c._stub.WaitForInstanceStart.call_args
  	if timeout is None or timeout == 0:
  	assert kwargs.get('timeout') is None
  	else:
  	assert kwargs.get('timeout') == timeout
  	@pytest.mark.parametrize("timeout", [None, 0, 5])
  	def test_wait_for_orchestration_completion_timeout(timeout):
  	instance_id = "test-instance"
  	from durabletask.internal.orchestrator_service_pb2 import GetInstanceResponse, \
  	OrchestrationState, ORCHESTRATION_STATUS_COMPLETED
  	response = GetInstanceResponse()
  	state = OrchestrationState()
  	state.instanceId = instance_id
  	state.orchestrationStatus = ORCHESTRATION_STATUS_COMPLETED
  	response.orchestrationState.CopyFrom(state)
  	c = TaskHubGrpcClient()
  	c._stub = Mock()
  	c._stub.WaitForInstanceCompletion.return_value = response
  	grpc_timeout = None if timeout is None else timeout
  	c.wait_for_orchestration_completion(instance_id, timeout=grpc_timeout)
  	# Verify WaitForInstanceStart was called with timeout=None
  	c._stub.WaitForInstanceCompletion.assert_called_once()
  	_, kwargs = c._stub.WaitForInstanceCompletion.call_args
  	if timeout is None or timeout == 0:
  	assert kwargs.get('timeout') is None
  	else:
  	assert kwargs.get('timeout') == timeout

  to a separate test file
• Kept protobuf files from the dapr fork. Updates on protobuf will come in a separate PR.
• Kept github workflows unchanged.

[mikeee]

Just some initial obs

[mikeee]

Suggested change

- Added new `durabletask-azuremanaged` package for use with the [Durable Task Scheduler](https://learn.microsoft.com/azure/azure-functions/durable/durable-task-scheduler/durable-task-scheduler) - by [@RyanLettieri](https://github.com/RyanLettieri)

I think the Changelog needs to be clarified for this fork

[elena-kolevska]

Suggested change

	2. Clone and run the [Durable Task Sidecar](https://github.com/microsoft/durabletask-go) project locally (requires Go 1.18 or higher). Orchestration state will be stored in a local sqlite database.
	2. Clone and run the [Durable Task Sidecar](https://github.com/dapr/durabletask-go) project locally (requires Go 1.18 or higher). Orchestration state will be stored in a local sqlite database.

[elena-kolevska]

Or to make it easier, we could give the exact commands:

go install github.com/dapr/durabletask-go@main
durabletask-go --port 4001

[elena-kolevska]

We already tried updating this dependency and there was a long discussion about it:
dapr/python-sdk#757 (comment)

I see this change is coming from upstream, but I'd like to understand what changed to make us change the decision we took in the comment above, cause all the raised points should still be valid.

[acroca]

The upstream commit doesn't have much information about why they changed it.
Do you think we should keep the version as it was?

[elena-kolevska]

Yeah, let's keep it please